home *** CD-ROM | disk | FTP | other *** search
/ PC World Komputer 2010 April / PCWorld0410.iso / pluginy Firefox / 684 / 684.xpi / chrome / fireftp.jar / content / js / connection / controlSocket.js < prev    next >
Text File  |  2009-12-06  |  96KB  |  2,447 lines
  1. // if you're actually interested in reusing this class for your app
  2. // it'd be a good idea to get in contact with me, Mime Cuvalo: mimecuvalo@gmail.com
  3.  
  4. function ftpMozilla(observer) {
  5.   this.transportService = Components.classes["@mozilla.org/network/socket-transport-service;1"].getService(Components.interfaces.nsISocketTransportService);
  6.   this.proxyService     = Components.classes["@mozilla.org/network/protocol-proxy-service;1"].getService  (Components.interfaces.nsIProtocolProxyService);
  7.   this.cacheService     = Components.classes["@mozilla.org/network/cache-service;1"].getService           (Components.interfaces.nsICacheService);
  8.   this.toUTF8           = Components.classes["@mozilla.org/intl/utf8converterservice;1"].getService       (Components.interfaces.nsIUTF8ConverterService);
  9.   this.fromUTF8         = Components.classes["@mozilla.org/intl/scriptableunicodeconverter"].getService   (Components.interfaces.nsIScriptableUnicodeConverter);
  10.   this.observer         = observer;
  11.  
  12.   this.eventQueue       = new Array();   // commands to be sent
  13.   this.trashQueue       = new Array();   // once commands are read, throw them away here b/c we might have to recycle these if there is an error
  14.   this.listData         = new Array();   // holds data directory data from the LIST command
  15.  
  16.   var self = this;
  17.   var func = function() { self.keepAlive(); };
  18.   setTimeout(func, 60000);
  19. }
  20.  
  21. ftpMozilla.prototype = {
  22.   // begin: variables you can set
  23.   host                 : "",
  24.   port                 : 21,
  25.   security             : "",
  26.   login                : "",
  27.   password             : "",
  28.   passiveMode          : true,
  29.   initialPath          : "",             // path we go to first onload
  30.   encoding             : "UTF-8",
  31.   type                 : '',             // what type of FTP connection is this? '' = standard, 'fxp' = FXP, 'transfer' = just for transfers
  32.   connNo               : 1,              // connection #
  33.   fxpHost              : null,           // the host of an FXP connection
  34.   timezone             : 0,              // timezone offset
  35.   privateKey           : "",             // private key for sftp connections
  36.  
  37.   asciiFiles           : new Array(),    // set to the list of extensions we treat as ASCII files when transfering
  38.   fileMode             : 0,              // 0 == auto, 1 == binary, 2 == ASCII
  39.   hiddenMode           : false,          // show hidden files if true
  40.   ipType               : "IPv4",         // right now, either IPv4 or IPv6
  41.   keepAliveMode        : true,           // keep the connection alive with NOOP's
  42.   networkTimeout       : 30,             // how many seconds b/f we consider the connection to be stale and dead
  43.   proxyHost            : "",
  44.   proxyPort            : 0,
  45.   proxyType            : "",
  46.   activePortMode       : false,          // in active mode, if you want to specify a range of ports
  47.   activeLow            : 1,              // low  port
  48.   activeHigh           : 65535,          // high port
  49.   reconnectAttempts    : 40,             // how many times we should try reconnecting
  50.   reconnectInterval    : 10,             // number of seconds in b/w reconnect attempts
  51.   reconnectMode        : true,           // true if we want to attempt reconnecting
  52.   sessionsMode         : true,           // true if we're caching directory data
  53.   timestampsMode       : false,          // true if we try to keep timestamps in sync
  54.   useCompression       : true,           // true if we try to do compression
  55.   integrityMode        : true,           // true if we try to do integrity checks
  56.  
  57.   errorConnectStr      : "Unable to make a connection.  Please try again.", // set to error msg that you'd like to show for a connection error
  58.   errorXCheckFail      : "The transfer of this file was unsuccessful and resulted in a corrupted file. It is recommended to restart this transfer.",  // an integrity check failure
  59.   passNotShown         : "(password not shown)",                            // set to text you'd like to show in place of password
  60.   l10nMonths           : new Array("Jan", "Feb", "Mar", "Apr", "May", "Jun", "Jul", "Aug", "Sep", "Oct", "Nov", "Dec"), // used in display localized months
  61.   // end: variables you can set
  62.  
  63.   // variables used internally
  64.   isConnected          : false,          // are we connected?
  65.   isReady              : false,          // are we busy writing/reading the control socket?
  66.   isReconnecting       : false,          // are we attempting a reconnect?
  67.   legitClose           : true,           // are we the ones initiating the close or is it a network error
  68.   reconnectsLeft       : 0,              // how many times more to try reconnecting
  69.   networkTimeoutID     : 0,              // a counter increasing with each read and write
  70.   transferID           : 0,              // a counter increasing with each transfer
  71.   queueID              : 0,              // another counter increasing with each transfer
  72.  
  73.   controlTransport     : null,
  74.   controlInstream      : null,
  75.   controlOutstream     : null,
  76.  
  77.   pipeTransport        : null,           // SFTP stuff
  78.   ipcBuffer            : null,
  79.   isKilling            : false,
  80.   readPoller           : 0,
  81.  
  82.   doingCmdBatch        : false,
  83.  
  84.   dataSocket           : null,
  85.   activeCurrentPort    : -1,             // if user specified a range of ports, this is the current port we're using
  86.  
  87.   featMLSD             : false,          // is the MLSD command available?
  88.   featMDTM             : false,          // is the MDTM command available?
  89.   featXMD5             : false,          // is the XMD5 command available?
  90.   featXSHA1            : false,          // is the XSHA1 command available?
  91.   featXCheck           : null,           // are the XMD5 or XSHA1 commands available; if so, which one to use?
  92.   featModeZ            : false,          // is the MODE Z command available?
  93.  
  94.   welcomeMessage       : "",             // hello world
  95.   fullBuffer           : "",             // full response of control socket
  96.   connectedHost        : "",             // name of the host we connect to plus username
  97.   localRefreshLater    : '',
  98.   remoteRefreshLater   : '',
  99.   waitToRefresh        : false,
  100.   transferMode         : "",             // either "A" or "I"
  101.   securityMode         : "",             // either "P" or "C" or ""
  102.   compressMode         : "S",            // either "S" or "Z"
  103.   currentWorkingDir    : "",             // directory that we're currently, uh, working with
  104.   version              : "1.0.7",  // version of this class - used to avoid collisions in cache
  105.   remoteMonths         : "Jan|Feb|Mar|Apr|May|Jun|Jul|Aug|Sep|Oct|Nov|Dec",         // used in parsing months from list data
  106.  
  107.   setSecurity : function(type) {
  108.     ftpMozilla.prototype.security = type;
  109.  
  110.     if (type == "sftp") {
  111.       for (func in this.sftp) {
  112.         eval("ftpMozilla.prototype." + func + " = ftpMozilla.prototype.sftp." + func);
  113.       }
  114.     } else {
  115.       for (func in this.ftp) {
  116.         eval("ftpMozilla.prototype." + func + " = ftpMozilla.prototype.ftp."  + func);
  117.       }
  118.     }
  119.   },
  120.  
  121.   onDisconnect : function(sslException) {
  122.     if (!this.isConnected) {                                                     // no route to host
  123.       if (!sslException && this.observer) {
  124.         this.observer.onAppendLog(this.errorConnectStr, 'error', "error");
  125.       }
  126.     }
  127.  
  128.     this.isConnected = false;
  129.  
  130.     if (this.dataSocket) {
  131.       this.dataSocket.kill();
  132.       this.dataSocket = null;
  133.     }
  134.  
  135.     if (this.observer) {
  136.       this.observer.onDisconnected(!this.legitClose && this.reconnectMode && this.reconnectsLeft > 0);
  137.       this.observer.onIsReadyChange(true);
  138.     }
  139.  
  140.     if (!this.legitClose && this.reconnectMode) {                                // try reconnecting
  141.       this.transferMode = "";
  142.       this.securityMode = "";
  143.       this.compressMode = "S";
  144.  
  145.       if (this.reconnectsLeft < 1) {
  146.         this.isReconnecting = false;
  147.         if (this.eventQueue.length && this.eventQueue[0].cmd == "welcome") {
  148.           this.eventQueue.shift();
  149.         }
  150.       } else {
  151.         this.isReconnecting = true;
  152.  
  153.         if (this.observer) {
  154.           this.observer.onReconnecting();
  155.         }
  156.  
  157.         var self = this;
  158.         var func = function() { self.reconnect(); };
  159.         setTimeout(func, this.reconnectInterval * 1000);
  160.       }
  161.     } else {
  162.       this.legitClose = true;
  163.       this.cleanup();
  164.     }
  165.  
  166.     if (this.security == "sftp") {
  167.       this.kill();
  168.     }
  169.   },
  170.  
  171.   disconnect : function() {
  172.     this.legitClose = true;                                                      // this close() is ok, don't try to reconnect
  173.     this.cleanup();
  174.  
  175.     if (!(!this.isConnected && this.eventQueue.length && this.eventQueue[0].cmd == "welcome")) {
  176.       try {
  177.         this.controlOutstream.write((this.security == "sftp" ? "quit" : "QUIT") + "\r\n", 6);
  178.         if (this.observer) {
  179.           this.observer.onAppendLog("       " + (this.security == "sftp" ? "quit" : "QUIT"), 'output', "info");
  180.         }
  181.       } catch(ex) { }
  182.     }
  183.  
  184.     if (this.dataSocket) {
  185.       this.dataSocket.kill();
  186.       this.dataSocket = null;
  187.     }
  188.  
  189.     this.kill();
  190.  
  191.     if (this.security == "sftp") {
  192.       this.onDisconnect();
  193.     }
  194.   },
  195.  
  196.   reconnect : function()  {                                                      // ahhhh! our precious connection has been lost,
  197.     if (!this.isReconnecting) {                                                  // must...get it...back...our...precious
  198.       return;
  199.     }
  200.  
  201.     --this.reconnectsLeft;
  202.  
  203.     this.connect(true);
  204.   },
  205.  
  206.   abort : function(forceKill) {
  207.     this.isReconnecting     = false;
  208.  
  209.     if (this.dataSocket) {
  210.       this.dataSocket.progressEventSink.bytesTotal = 0;                          // stop uploads
  211.       this.dataSocket.dataListener.bytesTotal      = 0;                          // stop downloads
  212.     }
  213.  
  214.     this.cleanup(true);
  215.  
  216.     if (!this.isConnected) {
  217.       return;
  218.     }
  219.  
  220.     if (forceKill && this.security != "sftp") {
  221.       try {
  222.         this.controlOutstream.write("ABOR\r\n", 6);
  223.       } catch(ex) { }
  224.     }
  225.  
  226.     //XXX this.writeControl("ABOR");                                             // ABOR does not seem to stop the connection in most cases
  227.     if (this.dataSocket) {                                                       // so this is a more direct approach
  228.       this.dataSocket.kill();
  229.       this.dataSocket = null;
  230.     } else {
  231.       this.isReady = true;
  232.     }
  233.  
  234.     this.addEventQueue("aborted");
  235.  
  236.     if (this.observer) {
  237.       this.observer.onAbort();
  238.     }
  239.   },
  240.  
  241.   cancel : function(forceKill) {                                                 // cancel current transfer
  242.     if (this.security == "sftp") {                                               // can't currently do this with sftp
  243.       return;
  244.     }
  245.  
  246.     if (this.dataSocket) {
  247.       this.dataSocket.progressEventSink.bytesTotal = 0;                          // stop uploads
  248.       this.dataSocket.dataListener.bytesTotal      = 0;                          // stop downloads
  249.     }
  250.  
  251.     this.trashQueue = new Array();
  252.  
  253.     if (forceKill && this.security != "sftp") {
  254.       try {
  255.         if (this.isConnected) {
  256.           this.controlOutstream.write("ABOR\r\n", 6);
  257.         }
  258.       } catch(ex) { }
  259.     }
  260.  
  261.     //XXX this.writeControl("ABOR");                                             // ABOR does not seem to stop the connection in most cases
  262.     var dId;
  263.     if (this.dataSocket && this.isConnected) {                                   // so this is a more direct approach
  264.       this.dataSocket.kill();
  265.       dId = this.dataSocket.id;
  266.       this.dataSocket = null;
  267.     }
  268.  
  269.     for (var x = 0; x < this.eventQueue.length; ++x) {
  270.       if (this.eventQueue[x].cmd == "transferEnd" && dId == this.eventQueue[x].callback.id) {
  271.         this.eventQueue.splice(0, x + 1);
  272.         break;
  273.       }
  274.     }
  275.  
  276.     if (this.isConnected) {
  277.       this.unshiftEventQueue("aborted");
  278.     }
  279.   },
  280.  
  281.   checkTimeout : function(id, cmd) {
  282.     if (this.isConnected && this.networkTimeoutID == id && this.eventQueue.length && this.eventQueue[0].cmd.indexOf(cmd) != -1) {
  283.       this.resetConnection();
  284.     }
  285.   },
  286.  
  287.   resetConnection : function() {
  288.     this.legitClose = false;                                                   // still stuck on a command so, try to restart the connection the hard way
  289.  
  290.     try {
  291.       this.controlOutstream.write((this.security == "sftp" ? "quit" : "QUIT") + "\r\n", 6);
  292.       if (this.observer) {
  293.         this.observer.onAppendLog("       " + (this.security == "sftp" ? "quit" : "QUIT"), 'output', "info");
  294.       }
  295.     } catch(ex) { }
  296.  
  297.     if (this.dataSocket) {
  298.       this.dataSocket.kill();
  299.       this.dataSocket = null;
  300.     }
  301.  
  302.     this.kill();
  303.  
  304.     if (this.security == "sftp") {
  305.       this.isConnected = false;
  306.     }
  307.   },
  308.  
  309.   cleanup : function(isAbort) {
  310.     this.eventQueue         = new Array();
  311.     this.trashQueue         = new Array();
  312.     this.transferMode       = "";
  313.     this.securityMode       = "";
  314.     this.compressMode       = "S";
  315.     this.currentWorkingDir  = "";
  316.     this.localRefreshLater  = "";
  317.     this.remoteRefreshLater = "";
  318.     this.waitToRefresh      = false;
  319.     this.fxpHost            = null;
  320.     this.isReady            = false;
  321.  
  322.     if (!isAbort) {
  323.       this.featMLSD         = false;
  324.       this.featMDTM         = false;
  325.       this.featXMD5         = false;
  326.       this.featXSHA1        = false;
  327.       this.featXCheck       = null;
  328.       this.featModeZ        = false;
  329.     }
  330.  
  331.     ++this.networkTimeoutID;
  332.     ++this.transferID;
  333.   },
  334.  
  335.   kill : function() {
  336.     try {
  337.       this.controlInstream.close();
  338.     } catch(ex) {
  339.       if (this.observer && this.security != "sftp") {
  340.         this.observer.onDebug(ex);
  341.       }
  342.     }
  343.  
  344.     try {
  345.       this.controlOutstream.close();
  346.     } catch(ex) {
  347.       if (this.observer) {
  348.         this.observer.onDebug(ex);
  349.       }
  350.     }
  351.  
  352.     if (this.security == "sftp") {
  353.       this.sftpKill();
  354.     }
  355.   },
  356.  
  357.   sftpKill : function() {
  358.     this.isKilling  = true;
  359.  
  360.     this.eventQueue = [];
  361.  
  362.     clearInterval(this.readPoller);
  363.  
  364.     try {
  365.       this.pipeTransport.cancel(-1);
  366.     } catch(ex) { }
  367.  
  368.     try {
  369.       this.ipcBuffer.shutdown();
  370.     } catch(ex) { }
  371.  
  372.     try {
  373.       this.pipeTransport.closeStdin();
  374.     } catch(ex) { }
  375.  
  376.     try {
  377.       if (this.getPlatform() == "windows") {
  378.         var killPath;
  379.  
  380.         var firefoxInstallPath = Components.classes["@mozilla.org/file/directory_service;1"].createInstance(Components.interfaces.nsIProperties)
  381.                                        .get("CurProcD", Components.interfaces.nsILocalFile);
  382.         killPath = firefoxInstallPath.path.substring(0, 2) + "/windows/system32/taskkill.exe /IM psftp.exe";
  383.         this.ipcService.exec(killPath);
  384.       } else {
  385.         var killPath = "/usr/bin/killall -9 psftp";
  386.         this.ipcService.exec(killPath);
  387.       }
  388.     } catch (ex) { }
  389.  
  390.     try {
  391.       this.pipeTransport.join();
  392.     } catch(ex) { }
  393.  
  394.     try {
  395.       this.pipeTransport.terminate();
  396.     } catch(ex) { }
  397.  
  398.     this.isKilling = false;
  399.   },
  400.  
  401.   addEventQueue : function(cmd, parameter, callback, callback2) {                // this just creates a new queue item
  402.     this.eventQueue.push(   { cmd: cmd, parameter: parameter || '', callback: callback || '', callback2: callback2 || '' });
  403.   },
  404.  
  405.   unshiftEventQueue : function(cmd, parameter, callback, callback2) {            // ditto
  406.     this.eventQueue.unshift({ cmd: cmd, parameter: parameter || '', callback: callback || '', callback2: callback2 || '' });
  407.   },
  408.  
  409.   beginCmdBatch : function() {
  410.     this.doingCmdBatch = true;
  411.   },
  412.  
  413.   writeControlWrapper : function() {
  414.     if (!this.doingCmdBatch) {
  415.       this.writeControl();
  416.     }
  417.   },
  418.  
  419.   endCmdBatch : function() {
  420.     this.doingCmdBatch = false;
  421.     this.writeControl();
  422.   },
  423.  
  424.   writeControl : function(cmd) {
  425.     try {
  426.       if (!this.isReady || (!cmd && !this.eventQueue.length)) {
  427.         return;
  428.       }
  429.  
  430.       var parameter;
  431.       var callback;
  432.       var callback2;
  433.  
  434.       if (!cmd) {
  435.         cmd        = this.eventQueue[0].cmd;
  436.         parameter  = this.eventQueue[0].parameter;
  437.         callback   = this.eventQueue[0].callback;
  438.         callback2  = this.eventQueue[0].callback2;
  439.       }
  440.  
  441.       if (cmd == "sftpcache") {
  442.         cmd       = parameter;
  443.         parameter = "";
  444.         callback  = "sftpcache";
  445.       }
  446.  
  447.       if (cmd == "custom") {
  448.         cmd       = parameter;
  449.         parameter = "";
  450.       }
  451.  
  452.       while (cmd == "aborted" || cmd == "goodbye"                                // these are sort of dummy values
  453.          ||  cmd == "transferBegin" || cmd == "transferEnd"
  454.          || (cmd == "TYPE" && this.transferMode      == parameter)               // or if we ignore TYPE if it's unnecessary
  455.          || (cmd == "PROT" && this.securityMode      == parameter)               // or if we ignore PROT if it's unnecessary
  456.          || (cmd == "MODE" && this.compressMode      == parameter)               // or if we ignore MODE if it's unnecessary
  457.          || (cmd == "CWD"  && this.currentWorkingDir == parameter                // or if we ignore CWD  if it's unnecessary
  458.             && this.type != 'transfer')
  459.          || (cmd == "cd"   && this.currentWorkingDir == parameter)) {
  460.  
  461.         if ((cmd == "TYPE" && this.transferMode      == parameter)
  462.          || (cmd == "PROT" && this.securityMode      == parameter)
  463.          || (cmd == "MODE" && this.compressMode      == parameter)
  464.          || (cmd == "CWD"  && this.currentWorkingDir == parameter)
  465.          || (cmd == "cd"   && this.currentWorkingDir == parameter)) {
  466.           this.trashQueue.push(this.eventQueue[0]);
  467.         }
  468.  
  469.         this.eventQueue.shift();
  470.  
  471.         if (this.eventQueue.length) {
  472.           cmd        = this.eventQueue[0].cmd;
  473.           parameter  = this.eventQueue[0].parameter;
  474.           callback   = this.eventQueue[0].callback;
  475.           callback2  = this.eventQueue[0].callback2;
  476.         } else {
  477.           return;
  478.         }
  479.       }
  480.  
  481.       this.isReady          = false;
  482.  
  483.       if (this.observer) {
  484.         this.observer.onIsReadyChange(false);
  485.       }
  486.  
  487.       if (!this.passiveMode && cmd == "PASV") {                                  // active mode
  488.         cmd                      = this.ipType == "IPv4" ? "PORT" : "EPRT";
  489.         var security             = this.security && this.securityMode == "P";
  490.         var proxy                = { proxyType: this.proxyType, proxyHost: this.proxyHost, proxyPort: this.proxyPort };
  491.         var currentPort          = this.activeCurrentPort == -1 ? this.activeLow : this.activeCurrentPort + 2;
  492.  
  493.         if (currentPort < this.activeLow || currentPort > this.activeHigh) {
  494.           currentPort = this.activeLow;
  495.         }
  496.  
  497.         this.activeCurrentPort   = currentPort;
  498.  
  499.         var qId;
  500.         for (var x = 0; x < this.eventQueue.length; ++x) {
  501.           if (this.eventQueue[x].cmd == "transferEnd") {
  502.             qId = this.eventQueue[x].callback.id;
  503.             break;
  504.           }
  505.         }
  506.  
  507.         this.dataSocket          = new ftpDataSocketMozilla(this.host, this.port, security, proxy, "", this.activePortMode ? currentPort : -1,
  508.                                                             this.compressMode == "Z", qId, this.observer, this.getCert(), this.fileMode == 2);
  509.  
  510.         var activeInfo           = {};
  511.         activeInfo.cmd           = this.eventQueue[1].cmd;
  512.         activeInfo.ipType        = this.ipType;
  513.  
  514.         if (this.eventQueue[1].cmd        == "RETR") {
  515.           activeInfo.localPath    = this.eventQueue[1].callback;
  516.           activeInfo.totalBytes   = callback;
  517.         } else if (this.eventQueue[1].cmd == "REST") {
  518.           activeInfo.localPath    = this.eventQueue[2].callback;
  519.           activeInfo.totalBytes   = callback;
  520.           activeInfo.partialBytes = this.eventQueue[1].parameter;
  521.         } else if (this.eventQueue[1].cmd == "STOR") {
  522.           activeInfo.localPath    = this.eventQueue[1].callback;
  523.         } else if (this.eventQueue[1].cmd == "APPE") {
  524.           activeInfo.localPath    = this.eventQueue[1].callback.localPath;
  525.           activeInfo.partialBytes = this.eventQueue[1].callback.remoteSize;
  526.         }
  527.  
  528.         parameter = this.dataSocket.createServerSocket(activeInfo);
  529.       }
  530.  
  531.       if (cmd == "PASV" && this.passiveMode && this.ipType != "IPv4") {
  532.         cmd = "EPSV";
  533.       }
  534.  
  535.       if (cmd == "LIST") {                                                       // don't include path in list command - breaks too many things
  536.         parameter = this.hiddenMode && !this.featMLSD ? "-al" : "";
  537.  
  538.         if (this.featMLSD) {
  539.           cmd = "MLSD";
  540.         }
  541.       }
  542.  
  543.       if (cmd == "ls") {
  544.         parameter = "";
  545.       }
  546.  
  547.       if (this.security == "sftp" && parameter && cmd != "chmod" && cmd != "mv" && cmd != "get" && cmd != "reget" && cmd != "put" && cmd != "reput") {
  548.         parameter = '"' + this.escapeSftp(parameter) + '"';
  549.       }
  550.  
  551.       var outputData = cmd + (parameter ? (' ' + parameter) : '') + "\r\n";      // le original bug fix! - thanks to devin
  552.  
  553.       try {
  554.         outputData   = this.fromUTF8.ConvertFromUnicode(outputData) + this.fromUTF8.Finish();
  555.       } catch (ex) {
  556.         if (this.observer) {
  557.           this.observer.onDebug(ex);
  558.         }
  559.       }
  560.  
  561.       this.controlOutstream.write(outputData, outputData.length);                // write!
  562.  
  563.       if (cmd != "get" && cmd != "reget" && cmd != "put" && cmd != "reput") {
  564.         ++this.networkTimeoutID;                                                   // this checks for timeout
  565.         var self           = this;
  566.         var currentTimeout = this.networkTimeoutID;
  567.         var func           = function() { self.checkTimeout(currentTimeout, cmd); };
  568.         setTimeout(func, this.networkTimeout * 1000);
  569.       }
  570.  
  571.       if ((cmd == "RETR" || cmd == "STOR" || cmd == "APPE") && callback2 != 'fxp') {
  572.         ++this.transferID;
  573.         var currentId    = this.transferID;
  574.         var func         = function() { self.checkDataTimeout(cmd == "RETR", currentId, 0); };
  575.         setTimeout(func, this.networkTimeout * 1000);
  576.       }
  577.  
  578.       outputData = cmd + (parameter ? (' ' + parameter) : '');                   // write it out to the log
  579.  
  580.       if (callback == "sftpcache") {
  581.         callback = null;
  582.       } else if (cmd != "PASS") {
  583.         if (this.observer) {
  584.           this.observer.onAppendLog("       "      + outputData,        'output', "info");
  585.         }
  586.       } else {
  587.         if (this.observer) {
  588.           this.observer.onAppendLog("       PASS " + this.passNotShown, 'output', "info");
  589.         }
  590.       }
  591.  
  592.     } catch(ex) {
  593.       if (this.observer) {
  594.         this.observer.onDebug(ex);
  595.         this.observer.onError(this.errorConnectStr);
  596.       }
  597.     }
  598.   },
  599.  
  600.   refresh : function() {
  601.     if (this.waitToRefresh) {
  602.       var self = this;
  603.       var func = function() { self.refresh(); };
  604.       setTimeout(func, 1000);
  605.       return;
  606.     } else if (this.eventQueue.length) {
  607.       return;
  608.     }
  609.  
  610.     if (this.localRefreshLater) {
  611.       var dir                 = new String(this.localRefreshLater);
  612.       this.localRefreshLater  = "";
  613.  
  614.       if (this.observer) {
  615.         this.observer.onShouldRefresh(true, false, dir);
  616.       }
  617.     }
  618.  
  619.     if (this.remoteRefreshLater) {
  620.       var dir                 = new String(this.remoteRefreshLater);
  621.       this.remoteRefreshLater = "";
  622.  
  623.       if (this.observer) {
  624.         this.observer.onShouldRefresh(false, true, dir);
  625.       }
  626.     }
  627.   },
  628.  
  629.   parseListData : function(data, path) {
  630.     /* Unix style:                     drwxr-xr-x  1 user01 ftp  512    Jan 29 23:32 prog
  631.      * Alternate Unix style:           drwxr-xr-x  1 user01 ftp  512    Jan 29 1997  prog
  632.      * Alternate Unix style:           drwxr-xr-x  1 1      1    512    Jan 29 23:32 prog
  633.      * SunOS style:                    drwxr-xr-x+ 1 1      1    512    Jan 29 23:32 prog
  634.      * A symbolic link in Unix style:  lrwxr-xr-x  1 user01 ftp  512    Jan 29 23:32 prog -> prog2000
  635.      * AIX style:                      drwxr-xr-x  1 user01 ftp  512    05 Nov 2003  prog
  636.      * Novell style:                   drwxr-xr-x  1 user01      512    Jan 29 23:32 prog
  637.      * Weird style:                    drwxr-xr-x  1 user5424867        Jan 29 23:32 prog, where 5424867 is the size
  638.      * Weird style 2:                  drwxr-xr-x  1 user01 anon5424867 Jan 11 12:48 prog, where 5424867 is the size
  639.      * MS-DOS style:                   01-29-97 11:32PM <DIR> prog
  640.      * OS/2 style:                     0           DIR 01-29-97  23:32  PROG
  641.      * OS/2 style:                     2243        RA  04-05-103 00:22  PJL
  642.      * OS/2 style:                     60              11-18-104 06:54  chkdsk.log
  643.      *
  644.      * MLSD style: type=file;size=6106;modify=20070223082414;UNIX.mode=0644;UNIX.uid=32257;UNIX.gid=32259;unique=808g154c727; prog
  645.      *             type=dir;sizd=4096;modify=20070218021044;UNIX.mode=0755;UNIX.uid=32257;UNIX.gid=32259;unique=808g1550003; prog
  646.      *             type=file;size=4096;modify=20070218021044;UNIX.mode=07755;UNIX.uid=32257;UNIX.gid=32259;unique=808g1550003; prog
  647.      *             type=OS.unix=slink:/blah;size=4096;modify=20070218021044;UNIX.mode=0755;UNIX.uid=32257;UNIX.gid=32259;unique=808g1550003; prog
  648.      */
  649.  
  650.     try {
  651.       data = this.toUTF8.convertStringToUTF8(data, this.encoding, 1);
  652.     } catch (ex) {
  653.       if (this.observer) {
  654.         this.observer.onDebug(ex);
  655.       }
  656.     }
  657.  
  658.     if (this.observer) {
  659.       this.observer.onDebug(data.replace(/</g, '<').replace(/>/g, '>'), "DEBUG");
  660.     }
  661.  
  662.     var items   = data.indexOf("\r\n") != -1 ? data.split("\r\n") : data.split("\n");
  663.     items       = items.filter(this.removeBlanks);
  664.     var curDate = new Date();
  665.  
  666.     if (items.length) {                                                          // some ftp servers send 'count <number>' or 'total <number>' first
  667.       if (items[0].indexOf("count") == 0 || items[0].indexOf("total") == 0 || items[0].indexOf("Listing directory") == 0 || (!this.featMLSD && items[0].split(" ").filter(this.removeBlanks).length == 2)) {
  668.         items.shift();                                                           // could be in german or croatian or what have you
  669.       }
  670.     }
  671.  
  672.     for (var x = 0; x < items.length; ++x) {
  673.       if (!items[x]) {                                                           // some servers put in blank lines b/w entries, aw, for cryin' out loud
  674.         items.splice(x, 1);
  675.         --x;
  676.         continue;
  677.       }
  678.  
  679.       items[x] = items[x].replace(/^\s+/, "");                                   // @*$% - some servers put blanks in front, do trimming on front
  680.  
  681.       var temp = items[x];                                                       // account for collisions:  drwxr-xr-x1017 user01
  682.  
  683.       if (!this.featMLSD) {
  684.         if (!parseInt(items[x].charAt(0)) && items[x].charAt(0) != '0' && items[x].charAt(10) == '+') {     // drwxr-xr-x+ - get rid of the plus sign
  685.           items[x] = this.setCharAt(items[x], 10, ' ');
  686.         }
  687.  
  688.         if (!parseInt(items[x].charAt(0)) && items[x].charAt(0) != '0' && items[x].charAt(10) != ' ') {     // this is mimicked below if weird style
  689.           items[x] = items[x].substring(0, 10) + ' ' + items[x].substring(10, items[x].length);
  690.         }
  691.  
  692.         items[x]   = items[x].split(" ").filter(this.removeBlanks);
  693.       }
  694.  
  695.       if (this.featMLSD) {                                                       // MLSD-standard style
  696.         var newItem    = { permissions : "----------",
  697.                            hardLink    : "",
  698.                            user        : "",
  699.                            group       : "",
  700.                            fileSize    : "0",
  701.                            date        : "",
  702.                            leafName    : "",
  703.                            isDir       : false,
  704.                            isDirectory : function() { return this.isDir },
  705.                            isSymlink   : function() { return this.symlink != "" },
  706.                            symlink     : "",
  707.                            path        : "" };
  708.  
  709.         var pathname     = items[x].split("; ");
  710.         newItem.leafName = '';
  711.         for (var y = 1; y < pathname.length; ++y) {
  712.           newItem.leafName += (y == 1 ? '' : '; ') + pathname[y];
  713.         }
  714.         newItem.path     = this.constructPath(path, newItem.leafName);
  715.  
  716.         items[x] = pathname[0];
  717.         items[x] = items[x].split(";");
  718.         var skip = false;
  719.  
  720.         for (var y = 0; y < items[x].length; ++y) {
  721.           if (!items[x][y]) {
  722.             continue;
  723.           }
  724.  
  725.           var fact = items[x][y].split('=');
  726.           if (fact.length < 2 || !fact[0] || !fact[1]) {
  727.             continue;
  728.           }
  729.  
  730.           var factName = fact[0].toLowerCase();
  731.           var factVal  = fact[1];
  732.  
  733.           switch (factName) {
  734.             case "type":
  735.               if (factVal == "pdir" || factVal == "cdir") {
  736.                 skip = true;
  737.               } else if (factVal == "dir") {
  738.                 newItem.isDir = true;
  739.                 newItem.permissions = this.setCharAt(newItem.permissions, 0, 'd');
  740.               } else if (items[x][y].substring(5).indexOf("OS.unix=slink:") == 0) {
  741.                 newItem.symlink = items[x][y].substring(19);
  742.                 newItem.permissions = this.setCharAt(newItem.permissions, 0, 'l');
  743.               } else if (factVal != "file") {
  744.                 skip = true;
  745.               }
  746.               break;
  747.             case "size":
  748.             case "sizd":
  749.               newItem.fileSize = factVal;
  750.               break;
  751.             case "modify":
  752.               var dateString = factVal.substr(0, 4) + " " + factVal.substr(4,  2) + " " + factVal.substr(6,  2) + " "
  753.                              + factVal.substr(8, 2) + ":" + factVal.substr(10, 2) + ":" + factVal.substr(12, 2) + " GMT";
  754.               var zeDate = new Date(dateString);
  755.               zeDate.setMinutes(zeDate.getMinutes() + this.timezone);
  756.               var timeOrYear = new Date() - zeDate > 15600000000 ? zeDate.getFullYear()    // roughly 6 months
  757.                              : this.zeroPadTime(zeDate.getHours()) + ":" + this.zeroPadTime(zeDate.getMinutes());
  758.               newItem.date = this.l10nMonths[zeDate.getMonth()] + ' ' + zeDate.getDate() + ' ' + timeOrYear;
  759.               newItem.lastModifiedTime = zeDate.getTime();
  760.               break;
  761.             case "unix.mode":
  762.               var offset = factVal.length == 5 ? 1 : 0;
  763.               var sticky = this.zeroPad(parseInt(factVal[0 + offset]).toString(2));
  764.               var owner  = this.zeroPad(parseInt(factVal[1 + offset]).toString(2));
  765.               var group  = this.zeroPad(parseInt(factVal[2 + offset]).toString(2));
  766.               var pub    = this.zeroPad(parseInt(factVal[3 + offset]).toString(2));
  767.               newItem.permissions = this.setCharAt(newItem.permissions, 1, owner[0]  == '1' ? 'r' : '-');
  768.               newItem.permissions = this.setCharAt(newItem.permissions, 2, owner[1]  == '1' ? 'w' : '-');
  769.               newItem.permissions = this.setCharAt(newItem.permissions, 3, sticky[0] == '1' ? (owner[2] == '1' ? 's' : 'S')
  770.                                                                                             : (owner[2] == '1' ? 'x' : '-'));
  771.               newItem.permissions = this.setCharAt(newItem.permissions, 4, group[0]  == '1' ? 'r' : '-');
  772.               newItem.permissions = this.setCharAt(newItem.permissions, 5, group[1]  == '1' ? 'w' : '-');
  773.               newItem.permissions = this.setCharAt(newItem.permissions, 6, sticky[1] == '1' ? (group[2] == '1' ? 's' : 'S')
  774.                                                                                             : (group[2] == '1' ? 'x' : '-'));
  775.               newItem.permissions = this.setCharAt(newItem.permissions, 7, pub[0]    == '1' ? 'r' : '-');
  776.               newItem.permissions = this.setCharAt(newItem.permissions, 8, pub[1]    == '1' ? 'w' : '-');
  777.               newItem.permissions = this.setCharAt(newItem.permissions, 9, sticky[2] == '1' ? (pub[2]   == '1' ? 't' : 'T')
  778.                                                                                             : (pub[2]   == '1' ? 'x' : '-'));
  779.               break;
  780.             case "unix.uid":
  781.               newItem.user = factVal;
  782.               break;
  783.             case "unix.gid":
  784.               newItem.group = factVal;
  785.               break;
  786.             default:
  787.               break;
  788.           }
  789.  
  790.           if (skip) {
  791.             break;
  792.           }
  793.         }
  794.  
  795.         if (skip) {
  796.           items.splice(x, 1);
  797.           --x;
  798.           continue;
  799.         }
  800.  
  801.         items[x] = newItem;
  802.       } else if (!parseInt(items[x][0].charAt(0)) && items[x][0].charAt(0) != '0')  {   // unix style - so much simpler with you guys
  803.         var offset = 0;
  804.  
  805.         if (items[x][3].search(this.remoteMonths) != -1 && items[x][5].search(this.remoteMonths) == -1) {
  806.           var weird = temp;                                                      // added to support weird servers
  807.  
  808.           if (weird.charAt(10) != ' ') {                                         // same as above code
  809.             weird = weird.substring(0, 10) + ' ' + weird.substring(10, weird.length);
  810.           }
  811.  
  812.           var weirdIndex = 0;
  813.  
  814.           for (var y = 0; y < items[x][2].length; ++y) {
  815.             if (parseInt(items[x][2].charAt(y))) {
  816.               weirdIndex = weird.indexOf(items[x][2]) + y;
  817.               break;
  818.             }
  819.           }
  820.  
  821.           weird    = weird.substring(0, weirdIndex) + ' ' + weird.substring(weirdIndex, weird.length);
  822.  
  823.           items[x] = weird.split(" ").filter(this.removeBlanks);
  824.         }
  825.  
  826.         if (items[x][4].search(this.remoteMonths) != -1 && !parseInt(items[x][3].charAt(0))) {
  827.           var weird = temp;                                                      // added to support 'weird 2' servers, oy vey
  828.  
  829.           if (weird.charAt(10) != ' ') {                                         // same as above code
  830.             weird = weird.substring(0, 10) + ' ' + weird.substring(10, weird.length);
  831.           }
  832.  
  833.           var weirdIndex = 0;
  834.  
  835.           for (var y = 0; y < items[x][3].length; ++y) {
  836.             if (parseInt(items[x][3].charAt(y))) {
  837.               weirdIndex = weird.indexOf(items[x][3]) + y;
  838.               break;
  839.             }
  840.           }
  841.  
  842.           weird    = weird.substring(0, weirdIndex) + ' ' + weird.substring(weirdIndex, weird.length);
  843.  
  844.           items[x] = weird.split(" ").filter(this.removeBlanks);
  845.         }
  846.  
  847.         if (items[x][4].search(this.remoteMonths) != -1) {                       // added to support novell servers
  848.           offset   = 1;
  849.         }
  850.  
  851.         var index = 0;
  852.         for (var y = 0; y < 7 - offset; ++y) {
  853.           index = temp.indexOf(items[x][y], index) + items[x][y].length + 1;
  854.         }
  855.  
  856.         var name    = temp.substring(temp.indexOf(items[x][7 - offset], index) + items[x][7 - offset].length + 1, temp.length);
  857.         name        = name.substring(name.search(/[^\s]/));
  858.         var symlink = "";
  859.  
  860.         if (items[x][0].charAt(0) == 'l') {
  861.           symlink = name;
  862.  
  863.           if (this.security != "sftp") {
  864.             name    = name.substring(0, name.indexOf("->") - 1);
  865.             symlink = symlink.substring(symlink.indexOf("->") + 3);
  866.           }
  867.         }
  868.  
  869.         name             = (name.lastIndexOf('/') == -1 ? name : name.substring(name.lastIndexOf('/') + 1));
  870.         var remotepath   = this.constructPath(path, name);
  871.         var month;
  872.  
  873.         var rawDate    = items[x][6 - offset];
  874.  
  875.         if (items[x][6].search(this.remoteMonths) != -1) {                       // added to support aix servers
  876.           month        = this.remoteMonths.search(items[x][6 - offset]) / 4;
  877.           rawDate      = items[x][5 - offset];
  878.         } else {
  879.           month        = this.remoteMonths.search(items[x][5 - offset]) / 4;
  880.         }
  881.  
  882.         var timeOrYear;
  883.         var curDate    = new Date();
  884.         var currentYr  = curDate.getMonth() < month ? curDate.getFullYear() - 1 : curDate.getFullYear();
  885.         var rawYear    = items[x][7 - offset].indexOf(':') != -1 ? currentYr            : parseInt(items[x][7 - offset]);
  886.         var rawTime    = items[x][7 - offset].indexOf(':') != -1 ? items[x][7 - offset] : "00:00";
  887.  
  888.         rawTime        = rawTime.split(":");
  889.  
  890.         for (var y = 0; y < rawTime.length; ++y) {
  891.           rawTime[y]   = parseInt(rawTime[y], 10);
  892.         }
  893.  
  894.         var parsedDate = new Date(rawYear, month, rawDate, rawTime[0], rawTime[1]);  // month-day-year format
  895.         parsedDate.setMinutes(parsedDate.getMinutes() + this.timezone);
  896.  
  897.         if (new Date() - parsedDate > 15600000000) {                             // roughly 6 months
  898.           timeOrYear   = parsedDate.getFullYear();
  899.         } else {
  900.           timeOrYear   = this.zeroPadTime(parsedDate.getHours()) + ":" + this.zeroPadTime(parsedDate.getMinutes());
  901.         }
  902.  
  903.         month          = this.l10nMonths[parsedDate.getMonth()];
  904.         items[x]       = { permissions : items[x][0],
  905.                            hardLink    : items[x][1],
  906.                            user        : items[x][2],
  907.                            group       : (offset ? "" : items[x][3]),
  908.                            fileSize    : items[x][4 - offset],
  909.                            date        : month + ' ' + parsedDate.getDate() + ' ' + timeOrYear,
  910.                            leafName    : name,
  911.                            isDir       : items[x][0].charAt(0) == 'd',
  912.                            isDirectory : function() { return this.isDir },
  913.                            isSymlink   : function() { return this.symlink != "" },
  914.                            symlink     : symlink,
  915.                            path        : remotepath };
  916.  
  917.       } else if (items[x][0].indexOf('-') == -1) {                               // os/2 style
  918.         var offset = 0;
  919.  
  920.         if (items[x][2].indexOf(':') != -1) {                                    // if "DIR" and "A" are missing
  921.           offset   = 1;
  922.         }
  923.  
  924.         var rawDate    = items[x][2 - offset].split("-");
  925.         var rawTime    = items[x][3 - offset];
  926.         var timeOrYear = rawTime;
  927.         rawTime        = rawTime.split(":");
  928.  
  929.         for (var y = 0; y < rawDate.length; ++y) {
  930.           rawDate[y]   = parseInt(rawDate[y], 10);                               // leading zeros are treated as octal so pass 10 as base argument
  931.         }
  932.  
  933.         for (var y = 0; y < rawTime.length; ++y) {
  934.           rawTime[y]   = parseInt(rawTime[y], 10);
  935.         }
  936.  
  937.         rawDate[2]     = rawDate[2] + 1900;                                      // ah, that's better
  938.         var parsedDate = new Date(rawDate[2], rawDate[0] - 1, rawDate[1], rawTime[0], rawTime[1]);  // month-day-year format
  939.         parsedDate.setMinutes(parsedDate.getMinutes() + this.timezone);
  940.  
  941.         if (new Date() - parsedDate > 15600000000) {                             // roughly 6 months
  942.           timeOrYear   = parsedDate.getFullYear();
  943.         } else {
  944.           timeOrYear   = this.zeroPadTime(parsedDate.getHours()) + ":" + this.zeroPadTime(parsedDate.getMinutes());
  945.         }
  946.  
  947.         var month      = this.l10nMonths[parsedDate.getMonth()];
  948.         var name       = temp.substring(temp.indexOf(items[x][3 - offset]) + items[x][3 - offset].length + 1, temp.length);
  949.         name           = name.substring(name.search(/[^\s]/));
  950.         name           = (name.lastIndexOf('/') == -1 ? name : name.substring(name.lastIndexOf('/') + 1));
  951.         items[x]       = { permissions : items[x][1] == "DIR" ? "d---------" : "----------",
  952.                            hardLink    : "",
  953.                            user        : "",
  954.                            group       : "",
  955.                            fileSize    : items[x][0],
  956.                            date        : month + ' ' + parsedDate.getDate() + ' ' + timeOrYear,
  957.                            leafName    : name,
  958.                            isDir       : items[x][1] == "DIR",
  959.                            isDirectory : function() { return this.isDir },
  960.                            isSymlink   : function() { return false },
  961.                            symlink     : "",
  962.                            path        : this.constructPath(path, name) };
  963.  
  964.       } else {                                                                   // ms-dos style
  965.         var rawDate    = items[x][0].split("-");
  966.         var amPm       = items[x][1].substring(5, 7);                            // grab PM or AM
  967.         var rawTime    = items[x][1].substring(0, 5);                            // get rid of PM, AM
  968.         var timeOrYear = rawTime;
  969.         rawTime        = rawTime.split(":");
  970.  
  971.         for (var y = 0; y < rawDate.length; ++y) {
  972.           rawDate[y]   = parseInt(rawDate[y], 10);
  973.         }
  974.  
  975.         for (var y = 0; y < rawTime.length; ++y) {
  976.           rawTime[y]   = parseInt(rawTime[y], 10);
  977.         }
  978.  
  979.         rawTime[0] = rawTime[0] == 12 && amPm == "AM" ? 0 : (rawTime[0] < 12 && amPm == "PM" ? rawTime[0] + 12 : rawTime[0]);
  980.  
  981.         if (rawDate[2] < 70) {                                                   // assuming you didn't have some files left over from 1904
  982.           rawDate[2]   = rawDate[2] + 2000;                                      // ah, that's better
  983.         } else {
  984.           rawDate[2]   = rawDate[2] + 1900;
  985.         }
  986.  
  987.         var parsedDate = new Date(rawDate[2], rawDate[0] - 1, rawDate[1], rawTime[0], rawTime[1]);  // month-day-year format
  988.         parsedDate.setMinutes(parsedDate.getMinutes() + this.timezone);
  989.  
  990.         if (new Date() - parsedDate > 15600000000) {                             // roughly 6 months
  991.           timeOrYear   = parsedDate.getFullYear();
  992.         } else {
  993.           timeOrYear   = this.zeroPadTime(parsedDate.getHours()) + ":" + this.zeroPadTime(parsedDate.getMinutes());
  994.         }
  995.  
  996.         var month      = this.l10nMonths[parsedDate.getMonth()];
  997.         var name       = temp.substring(temp.indexOf(items[x][2], temp.indexOf(items[x][1]) + items[x][1].length + 1)
  998.                          + items[x][2].length + 1, temp.length);
  999.         name           = name.substring(name.search(/[^\s]/));
  1000.         name           = (name.lastIndexOf('/') == -1 ? name : name.substring(name.lastIndexOf('/') + 1));
  1001.         items[x]       = { permissions : items[x][2] == "<DIR>" ? "d---------" : "----------",
  1002.                            hardLink    : "",
  1003.                            user        : "",
  1004.                            group       : "",
  1005.                            fileSize    : items[x][2] == "<DIR>" ? '0' : items[x][2],
  1006.                            date        : month + ' ' + parsedDate.getDate() + ' ' + timeOrYear,
  1007.                            leafName    : name,
  1008.                            isDir       : items[x][2] == "<DIR>",
  1009.                            isDirectory : function() { return this.isDir },
  1010.                            isSymlink   : function() { return false },
  1011.                            symlink     : "",
  1012.                            path        : this.constructPath(path, name) };
  1013.       }
  1014.  
  1015.       if (!items[x].lastModifiedTime) {
  1016.         var dateTemp  = items[x].date;                                             // this helps with sorting by date
  1017.         var dateMonth = dateTemp.substring(0, 3);
  1018.         var dateIndex = this.l10nMonths.indexOf(dateMonth);
  1019.         dateTemp      = this.remoteMonths.substr(dateIndex * 4, 3) + dateTemp.substring(3);
  1020.  
  1021.         if (items[x].date.indexOf(':') != -1) {
  1022.           dateTemp = dateTemp + ' ' + (curDate.getFullYear() - (curDate.getMonth() < dateIndex ? 1 : 0));
  1023.         }
  1024.  
  1025.         items[x].lastModifiedTime = Date.parse(dateTemp);
  1026.       }
  1027.  
  1028.       items[x].fileSize = parseInt(items[x].fileSize);
  1029.  
  1030.       items[x].parent = { path: items[x].path.substring(0, items[x].path.lastIndexOf('/') ? items[x].path.lastIndexOf('/') : 1) };
  1031.     }
  1032.  
  1033.     var directories = new Array();                                               // sort directories to the top
  1034.     var files       = new Array();
  1035.  
  1036.     for (var x = 0; x < items.length; ++x) {
  1037.       if (!this.hiddenMode && items[x].leafName.charAt(0) == ".") {              // don't show hidden files
  1038.         continue;
  1039.       }
  1040.  
  1041.       items[x].isHidden = items[x].leafName.charAt(0) == ".";
  1042.  
  1043.       items[x].leafName = items[x].leafName.replace(/[\\|\/]/g, '');             // scrub out / or \, a security vulnerability if file tries to do ..\..\blah.txt
  1044.       items[x].path     = this.constructPath(path, items[x].leafName);           // thanks to Tan Chew Keong for the heads-up
  1045.  
  1046.       if (items[x].leafName == "." || items[x].leafName == "..") {               // get rid of "." or "..", this can screw up things on recursive deletions
  1047.         continue;
  1048.       }
  1049.  
  1050.       if (items[x].isDirectory()) {
  1051.         directories.push(items[x]);
  1052.       } else {
  1053.         files.push(items[x]);
  1054.       }
  1055.     }
  1056.  
  1057.     items = directories.concat(files);
  1058.  
  1059.     if (this.sessionsMode) {
  1060.       try {                                                                      // put in cache
  1061.         var cacheSession = this.cacheService.createSession("fireftp", 1, true);
  1062.         var cacheDesc    = cacheSession.openCacheEntry((this.security == "sftp" ? "s" : "") + "ftp://" + this.version + this.connectedHost + path,
  1063.                                                        Components.interfaces.nsICache.ACCESS_WRITE, false);
  1064.         var cacheOut     = cacheDesc.openOutputStream(0);
  1065.         var cacheData    = items.toSource();
  1066.         cacheOut.write(cacheData, cacheData.length);
  1067.         cacheOut.close();
  1068.         cacheDesc.close();
  1069.       } catch (ex) {
  1070.         if (this.observer) {
  1071.           this.observer.onDebug(ex);
  1072.         }
  1073.       }
  1074.     }
  1075.  
  1076.     return items;
  1077.   },
  1078.  
  1079.   cacheHit : function(path, callback) {
  1080.     try {                                                                      // check the cache first
  1081.       var cacheSession   = this.cacheService.createSession("fireftp", 1, true);
  1082.       var cacheDesc      = cacheSession.openCacheEntry((this.security == "sftp" ? "s" : "") + "ftp://" + this.version + this.connectedHost + path,
  1083.                                                        Components.interfaces.nsICache.ACCESS_READ, false);
  1084.  
  1085.       if (cacheDesc.dataSize) {
  1086.         var cacheIn       = cacheDesc.openInputStream(0);
  1087.         var cacheInstream = Components.classes["@mozilla.org/binaryinputstream;1"].createInstance(Components.interfaces.nsIBinaryInputStream);
  1088.         cacheInstream.setInputStream(cacheIn);
  1089.         this.listData     = cacheInstream.readBytes(cacheInstream.available());
  1090.         this.listData     = eval(this.listData);
  1091.         cacheInstream.close();
  1092.         cacheDesc.close();
  1093.  
  1094.         if (this.observer) {
  1095.           this.observer.onDebug(this.listData.toSource().replace(/</g, '<').replace(/>/g, '>').replace(/, {/g, ',\n{')
  1096.                                              .replace(/isDirectory:\(function \(\) {return this.isDir;}\), isSymlink:\(function \(\) {return this.symlink != "";}\), /g, ''),
  1097.                                              "DEBUG-CACHE");
  1098.         }
  1099.  
  1100.         if (typeof callback == "string") {
  1101.           eval(callback);                                                      // send off list data to whoever wanted it
  1102.         } else {
  1103.           callback();
  1104.         }
  1105.  
  1106.         return true;
  1107.       }
  1108.  
  1109.       cacheDesc.close();
  1110.     } catch (ex) { }
  1111.  
  1112.     return false;
  1113.   },
  1114.  
  1115.   removeCacheEntry : function(path) {
  1116.     try {
  1117.       var cacheSession = this.cacheService.createSession("fireftp", 1, true);
  1118.       var cacheDesc    = cacheSession.openCacheEntry((this.security == "sftp" ? "s" : "") + "ftp://" + this.version + this.connectedHost + path,
  1119.                                                      Components.interfaces.nsICache.ACCESS_WRITE, false);
  1120.       cacheDesc.doom();
  1121.       cacheDesc.close();
  1122.     } catch (ex) {
  1123.       if (this.observer) {
  1124.         this.observer.onDebug(ex);
  1125.       }
  1126.     }
  1127.   },
  1128.  
  1129.   detectAscii : function(path) {                                                 // detect an ascii file - returns "A" or "I"
  1130.     if (this.fileMode == 1) {                                                    // binary
  1131.       return "I";
  1132.     }
  1133.  
  1134.     if (this.fileMode == 2) {                                                    // ASCII
  1135.       return "A";
  1136.     }
  1137.  
  1138.     path = path.substring(path.lastIndexOf('.') + 1);                            // manually detect
  1139.  
  1140.     for (var x = 0; x < this.asciiFiles.length; ++x) {
  1141.       if (this.asciiFiles[x].toLowerCase() == path.toLowerCase()) {
  1142.         return "A";
  1143.       }
  1144.     }
  1145.  
  1146.     return "I";
  1147.   },
  1148.  
  1149.   constructPath : function(parent, leafName) {
  1150.     return parent + (parent.charAt(parent.length - 1) != '/' ? '/' : '') + leafName;
  1151.   },
  1152.  
  1153.   removeBlanks : function(element, index, array) {
  1154.     return element;
  1155.   },
  1156.  
  1157.   zeroPad : function(str) {
  1158.     return str.length == 3 ? str : (str.length == 2 ? '0' + str : '00' + str);
  1159.   },
  1160.  
  1161.   zeroPadTime : function(num) {
  1162.     num = num.toString();
  1163.     return num.length == 2 ? num : '0' + num;
  1164.   },
  1165.  
  1166.   setCharAt : function(str, index, ch) {                                         // how annoying
  1167.     return str.substr(0, index) + ch + str.substr(index + 1);
  1168.   },
  1169.  
  1170.   setEncoding : function(encoding) {
  1171.     try {
  1172.       this.fromUTF8.charset = encoding;
  1173.       this.encoding         = encoding;
  1174.     } catch (ex) {
  1175.       this.fromUTF8.charset = "UTF-8";
  1176.       this.encoding         = "UTF-8";
  1177.     }
  1178.   },
  1179.  
  1180.   binaryToHex : function(input) {                                                // borrowed from nsUpdateService.js
  1181.     var result = "";
  1182.  
  1183.     for (var i = 0; i < input.length; ++i) {
  1184.       var hex = input.charCodeAt(i).toString(16);
  1185.  
  1186.       if (hex.length == 1) {
  1187.         hex = "0" + hex;
  1188.       }
  1189.  
  1190.       result += hex;
  1191.     }
  1192.  
  1193.     return result;
  1194.   },
  1195.  
  1196.   escapeSftp : function(str) {                                                   // thanks to Tan Chew Keong for the heads-up
  1197.     return str.replace(/"/g, '""');
  1198.   }
  1199. };
  1200.  
  1201. ftpMozilla.prototype.ftp = {
  1202.   connect : function(reconnect) {
  1203.     if (!reconnect) {                                                            // this is not a reconnection attempt
  1204.       this.isReconnecting = false;
  1205.       this.reconnectsLeft = parseInt(this.reconnectAttempts);
  1206.  
  1207.       if (!this.reconnectsLeft || this.reconnectsLeft < 1) {
  1208.         this.reconnectsLeft = 1;
  1209.       }
  1210.     }
  1211.  
  1212.     if (!this.eventQueue.length || this.eventQueue[0].cmd != "welcome") {
  1213.       this.unshiftEventQueue("welcome", "", "");                                 // wait for welcome message first
  1214.     }
  1215.  
  1216.     ++this.networkTimeoutID;                                                     // just in case we have timeouts from previous connection
  1217.     ++this.transferID;
  1218.  
  1219.     try {                                                                        // create a control socket
  1220.       var proxyInfo = null;
  1221.       var self      = this;
  1222.  
  1223.       if (this.proxyType != "") {                                                // use a proxy
  1224.         proxyInfo = this.proxyService.newProxyInfo(this.proxyType, this.proxyHost, this.proxyPort, 0, 30, null);
  1225.       }
  1226.  
  1227.       if (this.security == "ssl") {                                              // thanks to Scott Bentley. he's a good man, Jeffrey. and thorough.
  1228.         this.controlTransport = this.transportService.createTransport(["ssl"],      1, this.host, parseInt(this.port), proxyInfo);
  1229.       } else if (!this.security) {
  1230.         this.controlTransport = this.transportService.createTransport(null,         0, this.host, parseInt(this.port), proxyInfo);
  1231.       } else {
  1232.         this.controlTransport = this.transportService.createTransport(["starttls"], 1, this.host, parseInt(this.port), proxyInfo);
  1233.       }
  1234.  
  1235.       if (this.observer && this.observer.securityCallbacks) {
  1236.         this.observer.securityCallbacks.connection = this;
  1237.         this.controlTransport.securityCallbacks    = this.observer.securityCallbacks;
  1238.       }
  1239.  
  1240.       this.controlOutstream = this.controlTransport.openOutputStream(0, 0, 0);
  1241.       var controlStream     = this.controlTransport.openInputStream(0, 0, 0);
  1242.       this.controlInstream  = Components.classes["@mozilla.org/scriptableinputstream;1"].createInstance(Components.interfaces.nsIScriptableInputStream);
  1243.       this.controlInstream.init(controlStream);
  1244.  
  1245.       var dataListener = {                                                       // async data listener for the control socket
  1246.         data            : "",
  1247.  
  1248.         onStartRequest  : function(request, context) { },
  1249.  
  1250.         onStopRequest   : function(request, context, status) {
  1251.           self.onDisconnect();
  1252.         },
  1253.  
  1254.         onDataAvailable : function(request, context, inputStream, offset, count) {
  1255.           this.data = self.controlInstream.read(count);                          // read data
  1256.           self.readControl(this.data);
  1257.         }
  1258.       };
  1259.  
  1260.       var pump = Components.classes["@mozilla.org/network/input-stream-pump;1"].createInstance(Components.interfaces.nsIInputStreamPump);
  1261.       pump.init(controlStream, -1, -1, 0, 0, false);
  1262.       pump.asyncRead(dataListener, null);
  1263.  
  1264.     } catch(ex) {
  1265.       this.onDisconnect();
  1266.     }
  1267.   },
  1268.  
  1269.   getCert : function() {
  1270.     try {
  1271.       if (this.security) {
  1272.         return this.controlTransport.securityInfo.QueryInterface(Components.interfaces.nsISSLStatusProvider)
  1273.                                     .SSLStatus.QueryInterface(Components.interfaces.nsISSLStatus)
  1274.                                     .serverCert;
  1275.       }
  1276.     } catch(ex) {
  1277.       if (this.observer) {
  1278.         this.observer.onDebug(ex);
  1279.       }
  1280.     }
  1281.  
  1282.     return null;
  1283.   },
  1284.  
  1285.   checkDataTimeout : function(download, id, bytes) {
  1286.     if (this.isConnected && this.transferID == id && this.dataSocket) {
  1287.       if ((download && bytes == this.dataSocket.dataListener.bytesDownloaded)
  1288.       || (!download && bytes == this.dataSocket.progressEventSink.bytesUploaded)) {
  1289.         this.resetConnection();
  1290.         return;
  1291.       }
  1292.  
  1293.       var self      = this;
  1294.       var nextBytes = download ? self.dataSocket.dataListener.bytesDownloaded : self.dataSocket.progressEventSink.bytesUploaded;
  1295.       var func = function() { self.checkDataTimeout(download, id, nextBytes); };
  1296.       setTimeout(func, this.networkTimeout * 1000);
  1297.     }
  1298.   },
  1299.  
  1300.   keepAlive : function() {
  1301.     if (this.isConnected && this.keepAliveMode && this.eventQueue.length == 0) {
  1302.       this.addEventQueue("NOOP");
  1303.       this.writeControl();
  1304.     }
  1305.  
  1306.     var self = this;
  1307.     var func = function() { self.keepAlive(); };
  1308.     setTimeout(func, 60000);
  1309.   },
  1310.  
  1311.   readControl : function(buffer) {
  1312.     try {
  1313.       buffer = this.toUTF8.convertStringToUTF8(buffer, this.encoding, 1);
  1314.     } catch (ex) {
  1315.       if (this.observer) {
  1316.         this.observer.onDebug(ex);
  1317.       }
  1318.     }
  1319.  
  1320.     if ((buffer == "2" && !this.isConnected) || buffer == "\r\n" || buffer == "\n") {
  1321.       return;
  1322.     }
  1323.  
  1324.     var lastLineOfBuffer = buffer.indexOf("\r\n") != -1 ? buffer.split("\r\n") : buffer.split("\n");
  1325.     lastLineOfBuffer     = lastLineOfBuffer.filter(this.removeBlanks);
  1326.  
  1327.     if (buffer != "2") {                                                         // "2"s are self-generated fake messages
  1328.       for (var x = 0; x < lastLineOfBuffer.length; ++x) {                        // add response to log
  1329.         var message   = lastLineOfBuffer[x].charAt(lastLineOfBuffer[x].length - 1) == '\r'
  1330.                       ? lastLineOfBuffer[x].substring(0, lastLineOfBuffer[x].length - 1) : lastLineOfBuffer[x];
  1331.         var errorBlah = lastLineOfBuffer[x].charAt(0) == '4' || lastLineOfBuffer[x].charAt(0) == '5';
  1332.         if (!errorBlah) {
  1333.           if (this.observer) {
  1334.             this.observer.onAppendLog(message, 'input', "info");
  1335.           }
  1336.         }
  1337.       }
  1338.  
  1339.       ++this.networkTimeoutID;
  1340.     }
  1341.  
  1342.     lastLineOfBuffer = lastLineOfBuffer[lastLineOfBuffer.length - 1];            // we are only interested in what the last line says
  1343.     var returnCode;
  1344.  
  1345.     if ((lastLineOfBuffer.length > 3 && lastLineOfBuffer.charAt(3) == '-') || lastLineOfBuffer.charAt(0) == ' ') {
  1346.       if (this.eventQueue[0].cmd == "USER" || this.eventQueue[0].cmd == "PASS") {
  1347.         this.welcomeMessage += buffer;                                           // see if the message is finished or not
  1348.       }
  1349.  
  1350.       this.fullBuffer += buffer;
  1351.  
  1352.       return;
  1353.     } else {
  1354.       buffer          = this.fullBuffer + buffer;
  1355.       this.fullBuffer = '';
  1356.       returnCode = parseInt(lastLineOfBuffer.charAt(0));                         // looks at first number of number code
  1357.     }
  1358.  
  1359.     var cmd;  var parameter;    var callback;   var callback2;
  1360.  
  1361.     if (this.eventQueue.length) {
  1362.       cmd        = this.eventQueue[0].cmd;
  1363.       parameter  = this.eventQueue[0].parameter;
  1364.       callback   = this.eventQueue[0].callback;
  1365.       callback2  = this.eventQueue[0].callback2;
  1366.  
  1367.       if (cmd != "LIST"  && cmd != "RETR"  && cmd != "STOR"  && cmd != "APPE"    // used if we have a loss in connection
  1368.        && cmd != "LIST2" && cmd != "RETR2" && cmd != "STOR2" && cmd != "APPE2") {
  1369.         var throwAway = this.eventQueue.shift();
  1370.  
  1371.         if (throwAway.cmd != "USER"    && throwAway.cmd != "PASS"    && throwAway.cmd != "PWD"     && throwAway.cmd != "FEAT"
  1372.          && throwAway.cmd != "welcome" && throwAway.cmd != "goodbye" && throwAway.cmd != "aborted" && throwAway.cmd != "NOOP"
  1373.          && throwAway.cmd != "REST"    && throwAway.cmd != "SIZE"    && throwAway.cmd != "PBSZ"    && throwAway.cmd != "AUTH" && throwAway.cmd != "PROT") {
  1374.           this.trashQueue.push(throwAway);
  1375.         }
  1376.       }
  1377.     } else {
  1378.       cmd = "default";                                                           // an unexpected reply - perhaps a 421 timeout message
  1379.     }
  1380.  
  1381.     switch (cmd) {
  1382.       case "welcome":
  1383.         this.welcomeMessage = buffer;
  1384.  
  1385.         if (returnCode != 2) {
  1386.           if (this.observer) {
  1387.             this.observer.onConnectionRefused();
  1388.           }
  1389.  
  1390.           if (this.type == 'transfer') {
  1391.             this.type = 'bad';
  1392.           }
  1393.  
  1394.           this.cleanup();
  1395.  
  1396.           break;
  1397.         }
  1398.  
  1399.         this.isConnected       = true;                                           // good to go
  1400.  
  1401.         if (this.observer) {
  1402.           this.observer.onConnected();
  1403.         }
  1404.  
  1405.         this.isReconnecting    = false;
  1406.         this.reconnectsLeft    = parseInt(this.reconnectAttempts);               // setup reconnection settings
  1407.  
  1408.         if (!this.reconnectsLeft || this.reconnectsLeft < 1) {
  1409.           this.reconnectsLeft = 1;
  1410.         }
  1411.  
  1412.         this.unshiftEventQueue(  "USER", this.login, "");
  1413.  
  1414.         if (this.security) {
  1415.           this.unshiftEventQueue("PBSZ", "0",   "");
  1416.         }
  1417.  
  1418.         if (this.security == "authtls") {
  1419.           this.unshiftEventQueue("AUTH", "TLS", "");
  1420.         } else if (this.security == "authssl") {
  1421.           this.unshiftEventQueue("AUTH", "SSL", "");
  1422.         }
  1423.         break;
  1424.  
  1425.       case "AUTH":
  1426.         if (returnCode != 2) {
  1427.           if (this.observer) {
  1428.             this.observer.onError(buffer);
  1429.           }
  1430.  
  1431.           this.isConnected = false;
  1432.  
  1433.           this.kill();
  1434.  
  1435.           return;
  1436.         } else {
  1437.           var si = this.controlTransport.securityInfo;
  1438.           si.QueryInterface(Components.interfaces.nsISSLSocketControl);
  1439.           si.StartTLS();
  1440.         }
  1441.         break;
  1442.  
  1443.       case "PBSZ":
  1444.         if (returnCode != 2) {
  1445.           if (this.observer) {
  1446.             this.observer.onError(buffer);
  1447.           }
  1448.  
  1449.           this.isConnected = false;
  1450.  
  1451.           this.kill();
  1452.           return;
  1453.         }
  1454.         break;
  1455.  
  1456.       case "PROT":
  1457.         if (buffer.substring(0, 3) == "534" && parameter == "P") {
  1458.           if (this.observer) {
  1459.             this.observer.onAppendLog(buffer, 'error', "error");
  1460.           }
  1461.  
  1462.           this.unshiftEventQueue("PROT", "C", "");
  1463.           break;
  1464.         }
  1465.  
  1466.         if (returnCode != 2) {
  1467.           if (this.observer) {
  1468.             this.observer.onError(buffer);
  1469.           }
  1470.         } else {
  1471.           this.securityMode = parameter;
  1472.         }
  1473.         break;
  1474.  
  1475.       case "USER":
  1476.       case "PASS":
  1477.         if (returnCode == 2) {
  1478.           if (this.legitClose) {
  1479.             if (this.observer) {
  1480.               this.observer.onWelcomed();
  1481.             }
  1482.           }
  1483.  
  1484.           var newConnectedHost = this.login + "@" + this.host;
  1485.  
  1486.           if (this.observer) {
  1487.             this.observer.onLoginAccepted(newConnectedHost != this.connectedHost);
  1488.           }
  1489.  
  1490.           if (newConnectedHost != this.connectedHost) {
  1491.             this.legitClose = true;
  1492.           }
  1493.  
  1494.           this.connectedHost = newConnectedHost;                                 // switching to a different host or different login
  1495.  
  1496.           if (!this.legitClose) {
  1497.             this.recoverFromDisaster();                                          // recover from previous disaster
  1498.             break;
  1499.           }
  1500.  
  1501.           this.legitClose   = false;
  1502.  
  1503.           this.unshiftEventQueue("PWD",  "", "");
  1504.           this.unshiftEventQueue("FEAT", "", "");
  1505.         } else if (cmd == "USER" && returnCode == 3) {
  1506.           this.unshiftEventQueue("PASS", this.password, "");
  1507.         } else {
  1508.           if (this.observer && this.type == 'transfer') {
  1509.             this.observer.onLoginDenied();
  1510.           }
  1511.  
  1512.           this.cleanup();                                                        // login failed, cleanup variables
  1513.  
  1514.           if (this.observer && this.type != 'transfer' && this.type != 'bad') {
  1515.             this.observer.onError(buffer);
  1516.           }
  1517.  
  1518.           this.isConnected = false;
  1519.  
  1520.           this.kill();
  1521.  
  1522.           if (this.type == 'transfer') {
  1523.             this.type = 'bad';
  1524.           }
  1525.  
  1526.           if (this.observer && this.type != 'transfer' && this.type != 'bad') {
  1527.             var self = this;
  1528.             var func = function() { self.observer.onLoginDenied(); };
  1529.             setTimeout(func, 0);
  1530.           }
  1531.  
  1532.           return;
  1533.         }
  1534.         break;
  1535.  
  1536.       case "PASV":
  1537.         if (returnCode != 2) {
  1538.           if (this.observer) {
  1539.             this.observer.onError(buffer + ": " + this.constructPath(this.currentWorkingDir, this.eventQueue[(this.eventQueue[0].cmd == "REST" ? 1 : 0)].parameter));
  1540.           }
  1541.  
  1542.           if (this.observer && this.eventQueue[0].cmd != "LIST") {
  1543.             for (var x = 0; x < this.eventQueue.length; ++x) {
  1544.               if (this.eventQueue[x].cmd == "transferEnd") {
  1545.                 this.observer.onTransferFail(this.eventQueue[x].callback, buffer);
  1546.                 break;
  1547.               }
  1548.             }
  1549.           }
  1550.  
  1551.           if (this.eventQueue[0].cmd == "LIST") {
  1552.             this.eventQueue.shift();
  1553.           } else {
  1554.             while (this.eventQueue.length) {
  1555.               if (this.eventQueue[0].cmd == "transferEnd") {
  1556.                 this.eventQueue.shift();
  1557.                 break;
  1558.               }
  1559.  
  1560.               this.eventQueue.shift();
  1561.             }
  1562.           }
  1563.  
  1564.           break;
  1565.         }
  1566.  
  1567.         if (this.passiveMode) {
  1568.           var dataHost;
  1569.           var dataPort;
  1570.  
  1571.           if (callback2 == 'fxp') {
  1572.             callback(buffer.substring(buffer.indexOf("(") + 1, buffer.indexOf(")")));
  1573.             return;
  1574.           }
  1575.  
  1576.           if (this.ipType == "IPv4") {
  1577.             buffer           = buffer.substring(buffer.indexOf("(") + 1, buffer.indexOf(")"));
  1578.             var re           = /,/g;
  1579.             buffer           = buffer.replace(re, ".");                          // parsing the port to transfer to
  1580.             var lastDotIndex = buffer.lastIndexOf(".");
  1581.             dataPort         = parseInt(buffer.substring(lastDotIndex + 1));
  1582.             dataPort        += 256 * parseInt(buffer.substring(buffer.lastIndexOf(".", lastDotIndex - 1) + 1, lastDotIndex));
  1583.             dataHost         = buffer.substring(0, buffer.lastIndexOf(".", lastDotIndex - 1));
  1584.           } else {
  1585.             buffer           = buffer.substring(buffer.indexOf("(|||") + 4, buffer.indexOf("|)"));
  1586.             dataPort         = parseInt(buffer);
  1587.             dataHost         = this.host;
  1588.           }
  1589.  
  1590.           var isSecure       = this.security && this.securityMode == "P";
  1591.           var proxy          = { proxyType: this.proxyType, proxyHost: this.proxyHost, proxyPort: this.proxyPort };
  1592.  
  1593.           var qId;
  1594.           for (var x = 0; x < this.eventQueue.length; ++x) {
  1595.             if (this.eventQueue[x].cmd == "transferEnd") {
  1596.               qId = this.eventQueue[x].callback.id;
  1597.               break;
  1598.             }
  1599.           }
  1600.  
  1601.           this.dataSocket          = new ftpDataSocketMozilla(this.host, this.port, isSecure, proxy, dataHost, dataPort,
  1602.                                                               this.compressMode == "Z", qId, this.observer, this.getCert(), this.fileMode == 2);
  1603.  
  1604.           if (this.eventQueue[0].cmd        == "LIST") {                         // do what's appropriate
  1605.             this.dataSocket.connect();
  1606.           } else if (this.eventQueue[0].cmd == "RETR") {
  1607.             this.dataSocket.connect(false, this.eventQueue[0].callback,           callback);
  1608.           } else if (this.eventQueue[0].cmd == "REST") {
  1609.             this.dataSocket.connect(false, this.eventQueue[1].callback,           callback, this.eventQueue[0].parameter);
  1610.           } else if (this.eventQueue[0].cmd == "STOR") {
  1611.             this.dataSocket.connect(true,  this.eventQueue[0].callback,           0,        0);
  1612.           } else if (this.eventQueue[0].cmd == "APPE") {
  1613.             this.dataSocket.connect(true,  this.eventQueue[0].callback.localPath, 0,        this.eventQueue[0].callback.remoteSize);
  1614.           }
  1615.         }
  1616.         break;
  1617.  
  1618.       case "PORT":                                                               // only used with FXP
  1619.         if (returnCode != 2) {
  1620.           if (this.observer) {
  1621.             this.observer.onError(buffer + ": " + this.constructPath(this.currentWorkingDir, this.eventQueue[(this.eventQueue[0].cmd == "REST" ? 1 : 0)].parameter));
  1622.           }
  1623.  
  1624.           break;
  1625.         }
  1626.  
  1627.         break;
  1628.  
  1629.       case "APPE":
  1630.       case "LIST":
  1631.       case "RETR":
  1632.       case "STOR":
  1633.         this.eventQueue[0].cmd = cmd + "2";
  1634.  
  1635.         if (callback2 == 'fxp') {
  1636.           if (returnCode == 2) {
  1637.             ++this.transferID;
  1638.             this.eventQueue.shift();
  1639.             if (this.eventQueue.length && this.eventQueue[0].cmd == "transferEnd") {
  1640.               this.eventQueue.shift();
  1641.             }
  1642.             this.trashQueue = new Array();                                       // clear the trash array, completed an 'atomic' set of operations
  1643.  
  1644.             if (callback == 'dest' && (!this.fxpHost.eventQueue.length || (this.fxpHost.eventQueue[0].callback2 != 'fxp' && this.fxpHost.eventQueue[0].callback2 != 'fxpList'))) {
  1645.               this.disconnect();
  1646.             }
  1647.             break;
  1648.           }
  1649.  
  1650.           if (this.fxpHost) {
  1651.             this.fxpHost.isReady = true;
  1652.             this.fxpHost.writeControlWrapper();
  1653.           }
  1654.           return;
  1655.         }
  1656.  
  1657.         if (this.dataSocket.emptyFile) {                                         // XXX empty files are (still) special cases
  1658.           this.dataSocket.kill(true);
  1659.           this.dataSocket = null;
  1660.         }
  1661.  
  1662.         if (returnCode == 2) {
  1663.           if (this.dataSocket.finished) {
  1664.             ++this.transferID;
  1665.             this.eventQueue.shift();
  1666.             if (this.eventQueue.length && this.eventQueue[0].cmd == "transferEnd") {
  1667.               this.eventQueue.shift();
  1668.             }
  1669.             this.trashQueue = new Array();                                       // clear the trash array, completed an 'atomic' set of operations
  1670.  
  1671.             if (cmd == "LIST") {
  1672.               this.listData = this.parseListData(this.dataSocket.listData, parameter);
  1673.  
  1674.               if (typeof callback == "string") {
  1675.                 eval(callback);                                                  // send off list data to whoever wanted it
  1676.               } else {
  1677.                 callback();
  1678.               }
  1679.             }
  1680.  
  1681.             if (callback2) {                                                     // for transfers
  1682.               if (typeof callback2 == "string") {
  1683.                 eval(callback2);
  1684.               } else {
  1685.                 callback2();
  1686.               }
  1687.             }
  1688.  
  1689.             this.dataSocket = null;
  1690.  
  1691.             break;
  1692.           } else {
  1693.             var self = this;
  1694.             var func = function() { self.readControl("2"); };
  1695.             setTimeout(func, 500);                                               // give data stream some time to finish up
  1696.             return;
  1697.           }
  1698.         }
  1699.  
  1700.         if (returnCode != 1) {
  1701.           if (this.observer) {
  1702.             this.observer.onError(buffer + ": " + this.constructPath(this.currentWorkingDir, parameter));
  1703.           }
  1704.  
  1705.           this.eventQueue.shift();
  1706.           while (this.eventQueue.length && (this.eventQueue[0].cmd == "MDTM" || this.eventQueue[0].cmd == "XMD5" || this.eventQueue[0].cmd == "XSHA1" || this.eventQueue[0].cmd == "transferEnd")) {
  1707.             if (this.eventQueue[0].cmd == "transferEnd" && this.observer) {
  1708.               this.observer.onTransferFail(this.eventQueue[0].callback, buffer);
  1709.             }
  1710.  
  1711.             this.eventQueue.shift();
  1712.           }
  1713.           this.trashQueue = new Array();
  1714.  
  1715.           if (this.dataSocket) {
  1716.             this.dataSocket.kill();
  1717.             this.dataSocket = null;
  1718.           }
  1719.  
  1720.           break;
  1721.         }
  1722.         return;
  1723.  
  1724.       case "APPE2":
  1725.       case "RETR2":
  1726.       case "STOR2":
  1727.       case "LIST2":
  1728.         if (callback2 == 'fxp') {
  1729.           if (returnCode != 2) {
  1730.             if (this.observer) {
  1731.               this.observer.onError(buffer + ": " + this.constructPath(this.currentWorkingDir, parameter));
  1732.             }
  1733.           }
  1734.  
  1735.           ++this.transferID;
  1736.           this.eventQueue.shift();
  1737.           if (this.eventQueue.length && this.eventQueue[0].cmd == "transferEnd") {
  1738.             this.eventQueue.shift();
  1739.           }
  1740.           this.trashQueue = new Array();                                         // clear the trash array, completed an 'atomic' set of operations
  1741.  
  1742.           if (callback == 'dest' && (!this.fxpHost.eventQueue.length || (this.fxpHost.eventQueue[0].callback2 != 'fxp' && this.fxpHost.eventQueue[0].callback2 != 'fxpList'))) {
  1743.             this.disconnect();
  1744.           }
  1745.           break;
  1746.         }
  1747.  
  1748.         if (returnCode != 2) {
  1749.           if (this.observer) {
  1750.             this.observer.onError(buffer + ": " + this.constructPath(this.currentWorkingDir, parameter));
  1751.           }
  1752.  
  1753.           this.eventQueue.shift();
  1754.           while (this.eventQueue.length && (this.eventQueue[0].cmd == "MDTM" || this.eventQueue[0].cmd == "XMD5" || this.eventQueue[0].cmd == "XSHA1" || this.eventQueue[0].cmd == "transferEnd")) {
  1755.             if (this.eventQueue[0].cmd == "transferEnd" && this.observer) {
  1756.               this.observer.onTransferFail(this.eventQueue[0].callback, buffer);
  1757.             }
  1758.  
  1759.             this.eventQueue.shift();
  1760.           }
  1761.           this.trashQueue = new Array();
  1762.  
  1763.           if (this.dataSocket) {
  1764.             this.dataSocket.kill();
  1765.             this.dataSocket = null;
  1766.           }
  1767.           break;
  1768.         }
  1769.  
  1770.         if (!this.dataSocket || this.dataSocket.finished) {
  1771.           ++this.transferID;
  1772.           this.eventQueue.shift();
  1773.           if (this.eventQueue.length && this.eventQueue[0].cmd == "transferEnd") {
  1774.             this.eventQueue.shift();
  1775.           }
  1776.           this.trashQueue = new Array();                                         // clear the trash array, completed an 'atomic' set of operations
  1777.         }
  1778.  
  1779.         if (cmd == "LIST2" && this.dataSocket.finished) {
  1780.           this.listData = this.parseListData(this.dataSocket.listData, parameter);
  1781.           this.dataSocket = null;
  1782.  
  1783.           if (typeof callback == "string") {
  1784.             eval(callback);                                                      // send off list data to whoever wanted it
  1785.           } else {
  1786.             callback();
  1787.           }
  1788.         } else if ((!this.dataSocket || this.dataSocket.finished) && callback2) { // for transfers
  1789.           this.dataSocket = null;
  1790.           if (typeof callback2 == "string") {
  1791.             eval(callback2);
  1792.           } else {
  1793.             callback2();
  1794.           }
  1795.         } else if (this.dataSocket && !this.dataSocket.finished) {
  1796.           var self = this;
  1797.           var func = function() { self.readControl("2"); };
  1798.           setTimeout(func, 500);                                                 // give data stream some time to finish up
  1799.           return;
  1800.         } else if (this.dataSocket && this.dataSocket.finished) {
  1801.           this.dataSocket = null;
  1802.         }
  1803.         break;
  1804.  
  1805.       case "SIZE":
  1806.         if (returnCode == 2) {                                                   // used with APPE commands to see where to pick up from
  1807.           var size = buffer.split(" ").filter(this.removeBlanks);
  1808.           size     = parseInt(size[1]);
  1809.  
  1810.           for (var x = 0; x < this.eventQueue.length; ++x) {
  1811.             if (callback == this.eventQueue[x].cmd) {
  1812.               if (callback == "STOR") {
  1813.                 this.eventQueue[x].cmd      = "APPE";
  1814.                 this.eventQueue[x].callback = { localPath: this.eventQueue[x].callback,           remoteSize: size };
  1815.               } else if (callback == "APPE") {
  1816.                 this.eventQueue[x].callback = { localPath: this.eventQueue[x].callback.localPath, remoteSize: size };
  1817.               } else if (callback == "PASV") {
  1818.                 this.eventQueue[x].callback = size;
  1819.               }
  1820.  
  1821.               break;
  1822.             }
  1823.           }
  1824.         } else {                                                                 // our size command didn't work out, make sure we're not doing an APPE
  1825.           if (callback != "PASV") {
  1826.             for (var x = 0; x < this.eventQueue.length; ++x) {
  1827.               if (this.eventQueue[x].cmd == "APPE") {
  1828.                 this.eventQueue[x].cmd      = "STOR";
  1829.                 this.eventQueue[x].callback = this.eventQueue[x].callback.localPath;
  1830.                 break;
  1831.               }
  1832.             }
  1833.           }
  1834.  
  1835.           if (this.observer) {
  1836.             this.observer.onAppendLog(buffer, 'error', "error");
  1837.           }
  1838.         }
  1839.         break;
  1840.  
  1841.       case "XMD5":
  1842.       case "XSHA1":
  1843.         if (returnCode == 2) {
  1844.           var zeHash = buffer.split(" ").filter(this.removeBlanks);
  1845.           zeHash     = zeHash[1].replace(/\n|\r/g, "").toLowerCase();
  1846.  
  1847.           if (typeof callback == "function") {
  1848.             callback(zeHash);
  1849.             break;
  1850.           }
  1851.  
  1852.           try {
  1853.             var file = Components.classes['@mozilla.org/file/local;1'].createInstance(Components.interfaces.nsILocalFile);
  1854.             file.initWithPath(callback);
  1855.             var cryptoHash = cmd == "XMD5" ? Components.interfaces.nsICryptoHash.MD5 : Components.interfaces.nsICryptoHash.SHA1;
  1856.             var fstream    = Components.classes["@mozilla.org/network/file-input-stream;1"].createInstance(Components.interfaces.nsIFileInputStream);
  1857.             fstream.init(file, 1, 0, false);
  1858.             var gHashComp  = Components.classes["@mozilla.org/security/hash;1"].createInstance(Components.interfaces.nsICryptoHash);
  1859.             gHashComp.init(cryptoHash);
  1860.             gHashComp.updateFromStream(fstream, -1);
  1861.             var ourHash    = this.binaryToHex(gHashComp.finish(false)).toLowerCase();
  1862.             fstream.close();
  1863.  
  1864.             if (ourHash != zeHash) {
  1865.               if (this.observer) {
  1866.                 this.observer.onError("'" + callback + "' - " + this.errorXCheckFail);
  1867.  
  1868.                 for (var x = 0; x < this.eventQueue.length; ++x) {
  1869.                   if (this.eventQueue[x].cmd == "transferEnd") {
  1870.                     this.observer.onTransferFail(this.eventQueue[x].callback, "checksum");
  1871.                     break;
  1872.                   }
  1873.                 }
  1874.               }
  1875.             }
  1876.           } catch (ex) {
  1877.             if (this.observer) {
  1878.               this.observer.onDebug(ex);
  1879.             }
  1880.           }
  1881.         } else {                                                                 // our size command didn't work out, make sure we're not doing an APPE
  1882.           if (this.observer) {
  1883.             this.observer.onAppendLog(buffer, 'error', "error");
  1884.           }
  1885.         }
  1886.         break;
  1887.  
  1888.       case "MDTM":
  1889.         if (returnCode == 2) {
  1890.           var zeDate = buffer.split(" ").filter(this.removeBlanks);
  1891.           zeDate     = zeDate[1];
  1892.  
  1893.           try {
  1894.             var file = Components.classes['@mozilla.org/file/local;1'].createInstance(Components.interfaces.nsILocalFile);
  1895.             file.initWithPath(callback);
  1896.             file.lastModifiedTime = Date.parse(zeDate.substr(0, 4) + " " + zeDate.substr(4,  2) + " " + zeDate.substr(6,  2) + " "
  1897.                                              + zeDate.substr(8, 2) + ":" + zeDate.substr(10, 2) + ":" + zeDate.substr(12, 2) + " GMT");
  1898.           } catch (ex) {
  1899.             if (this.observer) {
  1900.               this.observer.onDebug(ex);
  1901.             }
  1902.           }
  1903.         } else {                                                                 // our size command didn't work out, make sure we're not doing an APPE
  1904.           if (this.observer) {
  1905.             this.observer.onAppendLog(buffer, 'error', "error");
  1906.           }
  1907.         }
  1908.         break;
  1909.  
  1910.       case "RNFR":
  1911.       case "REST":
  1912.         if (returnCode != 3) {
  1913.           if (cmd == "RNFR") {
  1914.             this.eventQueue = new Array();
  1915.             this.trashQueue = new Array();
  1916.           }
  1917.  
  1918.           if (this.observer) {
  1919.             this.observer.onError(buffer);                                       // should still be able to go on without this, just not with resuming
  1920.           }
  1921.  
  1922.           break;
  1923.         }
  1924.         break;
  1925.  
  1926.       case "MKD":
  1927.       case "SITE CHMOD":
  1928.       case "RNTO":
  1929.       case "DELE":
  1930.       case "RMD":
  1931.         if (returnCode != 2) {
  1932.           if (this.observer) {
  1933.             this.observer.onError(buffer + ": " + this.constructPath(this.currentWorkingDir, parameter));
  1934.           }
  1935.         } else {
  1936.           if (cmd == "RMD") {                                                    // clear out of cache if it's a remove directory
  1937.             this.removeCacheEntry(this.constructPath(this.currentWorkingDir, parameter));
  1938.           }
  1939.  
  1940.           if (typeof callback == "string") {
  1941.             eval(callback);                                                      // send off list data to whoever wanted it
  1942.           } else {
  1943.             callback();
  1944.           }
  1945.         }
  1946.  
  1947.         this.trashQueue = new Array();
  1948.         break;
  1949.  
  1950.       case "CWD":
  1951.         if (returnCode != 2) {                                                   // if it's not a directory
  1952.           if (callback && typeof callback == "function") {
  1953.             callback(false);
  1954.           } else if (this.type == 'transfer') {
  1955.             this.observer.onDebug(buffer);
  1956.             this.unshiftEventQueue(cmd, parameter, callback, callback2);
  1957.  
  1958.             var self = this;
  1959.             var func = function() { self.nextCommand(); };
  1960.             setTimeout(func, 500);                                               // give main connection time to create the directory
  1961.             return;
  1962.           } else if (this.observer) {
  1963.             this.observer.onDirNotFound(buffer);
  1964.  
  1965.             if (this.observer) {
  1966.               this.observer.onError(buffer);
  1967.             }
  1968.           }
  1969.         } else {
  1970.           this.currentWorkingDir = parameter;
  1971.  
  1972.           if (this.observer) {                                                   // else navigate to the directory
  1973.             this.observer.onChangeDir(parameter, typeof callback == "boolean" ? callback : "");
  1974.           }
  1975.  
  1976.           if (callback && typeof callback == "function") {
  1977.             callback(true);
  1978.           }
  1979.         }
  1980.         break;
  1981.  
  1982.       case "PWD":                                                                // gotta check for chrooted directories
  1983.         if (returnCode != 2) {
  1984.           if (this.observer) {
  1985.             this.observer.onError(buffer);
  1986.           }
  1987.         } else {
  1988.           buffer = buffer.substring(buffer.indexOf("\"") + 1, buffer.lastIndexOf("\""));              // if buffer is not '/' we're chrooted
  1989.           this.currentWorkingDir = buffer;
  1990.  
  1991.           if (this.observer) {
  1992.             this.observer.onChangeDir(buffer != '/' && this.initialPath == '' ? buffer : '', false, buffer != '/' || this.initialPath != '');
  1993.           }
  1994.  
  1995.           if (this.type == 'fxp') {
  1996.             this.list(this.initialPath ? this.initialPath : this.currentWorkingDir);
  1997.           }
  1998.         }
  1999.  
  2000.         this.trashQueue = new Array();
  2001.         break;
  2002.  
  2003.       case "FEAT":
  2004.         if (returnCode != 2) {
  2005.           if (this.observer) {
  2006.             this.observer.onAppendLog(buffer, 'error', "error");
  2007.           }
  2008.         } else {
  2009.           buffer = buffer.indexOf("\r\n") != -1 ? buffer.split("\r\n") : buffer.split("\n");
  2010.  
  2011.           for (var x = 0; x < buffer.length; ++x) {
  2012.             if (buffer[x] && buffer[x][0] == ' ') {
  2013.               var feat = buffer[x].replace(/^\s*/, "").replace(/\s*$/, "").toUpperCase();
  2014.               if (feat == "MDTM") {
  2015.                 this.featMDTM   = true;
  2016.               } else if (feat == "MLSD") {
  2017.                 this.featMLSD   = true;
  2018.               } else if (feat.indexOf("MODE Z") == 0) {
  2019.                 this.featModeZ  = true;
  2020.               } else if (feat.indexOf("XSHA1") == 0) {
  2021.                 this.featXCheck = "XSHA1";
  2022.                 this.featXSHA1  = true;
  2023.               } else if (feat.indexOf("XMD5") == 0 && !this.featXCheck) {
  2024.                 this.featXCheck = "XMD5";
  2025.               }
  2026.  
  2027.               if (feat.indexOf("XMD5") == 0) {
  2028.                 this.featXMD5  = true;
  2029.               }
  2030.             }
  2031.           }
  2032.         }
  2033.         break;
  2034.  
  2035.       case "aborted":
  2036.         break;
  2037.  
  2038.       case "TYPE":
  2039.         if (returnCode != 2) {
  2040.           if (this.observer) {
  2041.             this.observer.onError(buffer);
  2042.           }
  2043.         } else {
  2044.           this.transferMode = parameter;
  2045.         }
  2046.         break;
  2047.       case "MODE":
  2048.         if (returnCode != 2) {
  2049.           if (this.observer) {
  2050.             this.observer.onError(buffer);
  2051.           }
  2052.         } else {
  2053.           this.compressMode = parameter;
  2054.         }
  2055.         break;
  2056.       case "goodbye":                                                            // you say yes, i say no, you stay stop...
  2057.       case "NOOP":
  2058.       default:
  2059.         if (buffer.substring(0, 3) != "421" && returnCode != 2) {
  2060.           if (this.observer) {
  2061.             this.observer.onError(buffer);
  2062.           }
  2063.         }
  2064.         break;
  2065.     }
  2066.  
  2067.     this.nextCommand();
  2068.   },
  2069.  
  2070.   nextCommand : function() {
  2071.     this.isReady = true;
  2072.  
  2073.     if (this.observer) {
  2074.       this.observer.onIsReadyChange(true);
  2075.     }
  2076.  
  2077.     if (this.eventQueue.length && this.eventQueue[0].cmd != "welcome") {         // start the next command
  2078.       this.writeControl();
  2079.     } else {
  2080.       this.refresh();
  2081.     }
  2082.   },
  2083.  
  2084.   changeWorkingDirectory : function(path, callback) {
  2085.     this.addEventQueue("CWD", path, callback);
  2086.     this.writeControlWrapper();
  2087.   },
  2088.  
  2089.   makeDirectory : function(path, callback) {
  2090.     this.addEventQueue("CWD", path.substring(0, path.lastIndexOf('/') ? path.lastIndexOf('/') : 1), true);
  2091.     this.addEventQueue("MKD", path.substring(path.lastIndexOf('/') + 1), callback);
  2092.     this.writeControlWrapper();
  2093.   },
  2094.  
  2095.   makeBlankFile : function(path, callback) {
  2096.     this.addEventQueue("CWD", path.substring(0, path.lastIndexOf('/') ? path.lastIndexOf('/') : 1), true);
  2097.  
  2098.     try {
  2099.       var count = 0;
  2100.       let tmpFile = Components.classes["@mozilla.org/file/directory_service;1"].createInstance(Components.interfaces.nsIProperties).get("TmpD", Components.interfaces.nsILocalFile);
  2101.       tmpFile.append(count + '-blankFile');
  2102.       while (tmpFile.exists()) {
  2103.         ++count;
  2104.         tmpFile.leafName = count + '-blankFile';
  2105.       }
  2106.       var foutstream = Components.classes["@mozilla.org/network/file-output-stream;1"].createInstance(Components.interfaces.nsIFileOutputStream);
  2107.       foutstream.init(tmpFile, 0x04 | 0x08 | 0x20, 0644, 0);
  2108.       foutstream.write("", 0);
  2109.       foutstream.close();
  2110.  
  2111.       this.upload(tmpFile.path, path, false, 0, 0, callback, true);
  2112.     } catch (ex) {
  2113.       if (this.observer) {
  2114.         this.observer.onDebug(ex);
  2115.       }
  2116.     }
  2117.   },
  2118.  
  2119.   remove : function(isDirectory, path, callback) {
  2120.     if (isDirectory) {
  2121.       this.unshiftEventQueue("RMD",    path.substring(path.lastIndexOf('/') + 1), callback);
  2122.       this.unshiftEventQueue("CWD",    path.substring(0, path.lastIndexOf('/') ? path.lastIndexOf('/') : 1), true);
  2123.  
  2124.       var self         = this;
  2125.       var listCallback = function() { self.removeRecursive(path); };
  2126.       this.list(path, listCallback, true, true);
  2127.     } else {
  2128.       this.unshiftEventQueue("DELE",   path.substring(path.lastIndexOf('/') + 1), callback);
  2129.       this.unshiftEventQueue("CWD",    path.substring(0, path.lastIndexOf('/') ? path.lastIndexOf('/') : 1), true);
  2130.     }
  2131.  
  2132.     this.writeControlWrapper();
  2133.   },
  2134.  
  2135.   removeRecursive : function(parent) {                                           // delete subdirectories and files
  2136.     var files = this.listData;
  2137.  
  2138.     for (var x = 0; x < files.length; ++x) {
  2139.       var remotePath = this.constructPath(parent, files[x].leafName);
  2140.  
  2141.       if (files[x].isDirectory()) {                                              // delete a subdirectory recursively
  2142.         this.unshiftEventQueue("RMD",  remotePath.substring(remotePath.lastIndexOf('/') + 1), "");
  2143.         this.unshiftEventQueue("CWD",  parent, true);
  2144.         this.removeRecursiveHelper(remotePath);
  2145.       } else {                                                                   // delete a file
  2146.         this.unshiftEventQueue("DELE", remotePath.substring(remotePath.lastIndexOf('/') + 1), "");
  2147.         this.unshiftEventQueue("CWD",  parent, true);
  2148.       }
  2149.     }
  2150.   },
  2151.  
  2152.   removeRecursiveHelper : function(remotePath) {
  2153.     var self           = this;
  2154.     var listCallback   = function() { self.removeRecursive(remotePath); };
  2155.     this.list(remotePath, listCallback, true, true);
  2156.   },
  2157.  
  2158.   rename : function(oldName, newName, callback, isDir) {
  2159.     if (isDir) {
  2160.       this.removeCacheEntry(oldName);
  2161.     }
  2162.  
  2163.     this.addEventQueue("RNFR", oldName);                                         // rename the file
  2164.     this.addEventQueue("RNTO", newName, callback);
  2165.     this.writeControlWrapper();
  2166.   },
  2167.  
  2168.   changePermissions : function(permissions, path, callback) {
  2169.     this.addEventQueue("CWD",        path.substring(0, path.lastIndexOf('/') ? path.lastIndexOf('/') : 1), true);
  2170.     this.addEventQueue("SITE CHMOD", permissions + ' ' + path.substring(path.lastIndexOf('/') + 1), callback);
  2171.     this.writeControlWrapper();
  2172.   },
  2173.  
  2174.   custom : function(cmd) {
  2175.     this.addEventQueue(cmd);
  2176.     this.writeControlWrapper();
  2177.   },
  2178.  
  2179.   list : function(path, callback, skipCache, recursive, fxp) {
  2180.     if (!skipCache && this.sessionsMode) {
  2181.       if (this.cacheHit(path, callback)) {
  2182.         return;
  2183.       }
  2184.     }
  2185.  
  2186.     var callback2 = fxp ? 'fxpList' : '';
  2187.  
  2188.     if (recursive) {
  2189.       this.unshiftEventQueue(  "LIST", path, callback, callback2);
  2190.       this.unshiftEventQueue(  "PASV",   "", "",       callback2);
  2191.       this.unshiftEventQueue(  "CWD",  path, "",       callback2);
  2192.  
  2193.       if (this.security) {
  2194.         this.unshiftEventQueue("PROT",  "P", "",       callback2);
  2195.       }
  2196.  
  2197.       this.unshiftEventQueue(  "MODE",  this.useCompression && this.featModeZ ? "Z" : "S", null, callback2);
  2198.       this.unshiftEventQueue(  "TYPE",  "A", "",       callback2);
  2199.     } else {
  2200.       this.addEventQueue(      "TYPE",  "A", "",       callback2);
  2201.       this.addEventQueue(      "MODE",  this.useCompression && this.featModeZ ? "Z" : "S", null, callback2);
  2202.  
  2203.       if (this.security) {
  2204.         this.addEventQueue(    "PROT",  "P", "",       callback2);
  2205.       }
  2206.  
  2207.       this.addEventQueue(      "CWD",  path, "",       callback2);
  2208.       this.addEventQueue(      "PASV",   "", "",       callback2);
  2209.       this.addEventQueue(      "LIST", path, callback, callback2);
  2210.     }
  2211.  
  2212.     this.writeControlWrapper();
  2213.   },
  2214.  
  2215.   download : function(remotePath, localPath, remoteSize, resume, localSize, isSymlink, callback) {
  2216.     ++this.queueID;
  2217.     var id = this.connNo + "-" + this.queueID;
  2218.  
  2219.     this.addEventQueue("transferBegin", "", { id: id });
  2220.  
  2221.     this.addEventQueue(  "CWD",  remotePath.substring(0, remotePath.lastIndexOf('/') ? remotePath.lastIndexOf('/') : 1), true);
  2222.  
  2223.     var leafName = remotePath.substring(remotePath.lastIndexOf('/') + 1);
  2224.  
  2225.     var ascii    = this.detectAscii(remotePath);
  2226.  
  2227.     this.addEventQueue(  "TYPE", ascii);
  2228.  
  2229.     this.addEventQueue(  "MODE", this.useCompression && this.featModeZ ? "Z" : "S");
  2230.  
  2231.     if (isSymlink) {
  2232.       this.addEventQueue("SIZE", leafName, "PASV");  // need to do a size check
  2233.     }
  2234.  
  2235.     if (this.security) {
  2236.       this.addEventQueue("PROT", "P");
  2237.     }
  2238.  
  2239.     this.addEventQueue(  "PASV", "", remoteSize, remoteSize);
  2240.  
  2241.     if (resume && ascii != 'A') {
  2242.       this.addEventQueue("REST", localSize);
  2243.     }
  2244.  
  2245.     this.addEventQueue(  "RETR", leafName, localPath, callback);
  2246.  
  2247.     if (this.integrityMode && this.featXCheck && ascii != 'A') {
  2248.       this.addEventQueue(this.featXCheck, '"' + leafName + '"', localPath);
  2249.     }
  2250.  
  2251.     if (this.timestampsMode && this.featMDTM) {
  2252.       this.addEventQueue("MDTM", leafName, localPath);
  2253.     }
  2254.  
  2255.     this.addEventQueue("transferEnd", "", { localPath: localPath, remotePath: remotePath, size: remoteSize, transport: 'ftp', type: 'download', ascii: ascii, id: id });
  2256.  
  2257.     this.writeControlWrapper();
  2258.   },
  2259.  
  2260.   upload : function(localPath, remotePath, resume, localSize, remoteSize, callback, disableMDTM) {
  2261.     ++this.queueID;
  2262.     var id = this.connNo + "-" + this.queueID;
  2263.  
  2264.     this.addEventQueue("transferBegin", "", { id: id });
  2265.  
  2266.     this.addEventQueue(  "CWD",  remotePath.substring(0, remotePath.lastIndexOf('/') ? remotePath.lastIndexOf('/') : 1), true);
  2267.  
  2268.     var leafName = remotePath.substring(remotePath.lastIndexOf('/') + 1);
  2269.  
  2270.     var ascii    = this.detectAscii(remotePath);
  2271.  
  2272.     this.addEventQueue(  "TYPE", ascii);
  2273.  
  2274.     this.addEventQueue(  "MODE", this.useCompression && this.featModeZ && ascii != 'A' ? "Z" : "S");  // XXX can't do compression with ascii mode in upload currently
  2275.  
  2276.     if (resume && ascii != 'A') {
  2277.       this.addEventQueue("SIZE", leafName, "APPE");                              // need to do a size check
  2278.     }
  2279.  
  2280.     if (this.security) {
  2281.       this.addEventQueue("PROT", "P");
  2282.     }
  2283.  
  2284.     this.addEventQueue(  "PASV", null, null, localSize);
  2285.  
  2286.     if (resume && ascii != 'A') {
  2287.       this.addEventQueue("APPE", leafName, { localPath: localPath, remoteSize: remoteSize }, callback);
  2288.     } else {
  2289.       this.addEventQueue("STOR", leafName,   localPath, callback);
  2290.     }
  2291.  
  2292.     if (this.integrityMode && this.featXCheck && ascii != 'A') {
  2293.       this.addEventQueue(this.featXCheck, '"' + leafName + '"', localPath);
  2294.     }
  2295.  
  2296.     if (this.timestampsMode && this.featMDTM && !disableMDTM) {
  2297.       this.addEventQueue("MDTM", leafName, localPath);
  2298.     }
  2299.  
  2300.     this.addEventQueue("transferEnd", "", { localPath: localPath, remotePath: remotePath, size: localSize, transport: 'ftp', type: 'upload', ascii: ascii, id: id });
  2301.  
  2302.     this.writeControlWrapper();
  2303.  
  2304.     return id;
  2305.   },
  2306.  
  2307.   fxp : function(hostPath, destPath, resume, destSize, hostSize) {
  2308.     ++this.fxpHost.queueID;
  2309.     var id = this.fxpHost.connNo + "-" + this.fxpHost.queueID;
  2310.  
  2311.     var leafName = hostPath.substring(hostPath.lastIndexOf('/') + 1);
  2312.  
  2313.     var self = this;
  2314.     var func = function(hostPort) { self.fxpCallback(hostPort, destPath, resume, destSize, id); };
  2315.  
  2316.     this.fxpHost.addEventQueue("transferBegin", "", { id: id }, 'fxp');
  2317.  
  2318.     this.fxpHost.addEventQueue(  "CWD",  hostPath.substring(0, hostPath.lastIndexOf('/') ? hostPath.lastIndexOf('/') : 1), true, 'fxp');
  2319.  
  2320.     var ascii = this.detectAscii(hostPath);
  2321.  
  2322.     this.fxpHost.addEventQueue(  "TYPE", ascii, null, 'fxp');
  2323.  
  2324.     this.fxpHost.addEventQueue(  "MODE", this.useCompression && this.fxpHost.featModeZ && this.featModeZ ? "Z" : "S", null, 'fxp');
  2325.  
  2326.     if (resume && ascii != 'A') {
  2327.       this.fxpHost.addEventQueue("REST", destSize, null, 'fxp');
  2328.     }
  2329.  
  2330.     this.fxpHost.addEventQueue(  "PASV", "", func, 'fxp');
  2331.  
  2332.     this.fxpHost.addEventQueue(  "RETR", leafName, 'host', 'fxp');
  2333.  
  2334.     this.fxpHost.addEventQueue("transferEnd", "",  { localPath: hostPath, remotePath: destPath, size: hostSize, transport: 'fxp', type: 'fxp', ascii: ascii, id: id }, 'fxp');
  2335.  
  2336.     this.fxpHost.writeControlWrapper();
  2337.   },
  2338.  
  2339.   fxpCallback : function(hostPort, destPath, resume, destSize, id) {
  2340.     var leafName = destPath.substring(destPath.lastIndexOf('/') + 1);
  2341.  
  2342.     this.fxpHost.addEventQueue("transferBegin", "", { id: id }, 'fxp');
  2343.  
  2344.     this.addEventQueue(   "CWD",  destPath.substring(0, destPath.lastIndexOf('/') ? destPath.lastIndexOf('/') : 1), true, 'fxp');
  2345.  
  2346.     this.addEventQueue(   "TYPE", this.detectAscii(leafName), null, 'fxp');
  2347.  
  2348.     this.addEventQueue(   "MODE", this.useCompression && this.fxpHost.featModeZ && this.featModeZ ? "Z" : "S", null, 'fxp');
  2349.  
  2350.     if (resume) {
  2351.       this.addEventQueue( "REST", destSize, null, 'fxp');
  2352.     }
  2353.  
  2354.     this.addEventQueue(   "PORT", hostPort, null, 'fxp');
  2355.  
  2356.     this.addEventQueue(   "STOR", leafName, 'dest', 'fxp');
  2357.  
  2358.     this.fxpHost.addEventQueue("transferEnd", "",  { transport: 'fxp', type: 'fxp', id: id }, 'fxp');
  2359.  
  2360.     this.writeControlWrapper();
  2361.   },
  2362.  
  2363.   isListing : function() {                                                       // check queue to see if we're listing
  2364.     for (var x = 0; x < this.eventQueue.length; ++x) {
  2365.       if (this.eventQueue[x].cmd.indexOf("LIST") != -1) {
  2366.         return true;
  2367.       }
  2368.     }
  2369.  
  2370.     return false;
  2371.   },
  2372.  
  2373.   recoverFromDisaster : function() {                                             // after connection lost, try to restart queue
  2374.     if (this.eventQueue.length && this.eventQueue[0].cmd == "goodbye") {
  2375.       this.eventQueue.shift();
  2376.     }
  2377.  
  2378.     if (this.eventQueue.cmd) {
  2379.       this.eventQueue = new Array(this.eventQueue);
  2380.     }
  2381.  
  2382.     while (this.eventQueue.length && (this.eventQueue[0].callback2 == "fxp" || this.eventQueue[0].callback2 == "fxpList")) {
  2383.       this.eventQueue.shift();
  2384.     }
  2385.  
  2386.     if (this.eventQueue.length && (this.eventQueue[0].cmd == "LIST" || this.eventQueue[0].cmd == "LIST2"
  2387.                                ||  this.eventQueue[0].cmd == "RETR" || this.eventQueue[0].cmd == "RETR2"
  2388.                                ||  this.eventQueue[0].cmd == "REST" || this.eventQueue[0].cmd == "APPE"
  2389.                                ||  this.eventQueue[0].cmd == "STOR" || this.eventQueue[0].cmd == "STOR2"
  2390.                                ||  this.eventQueue[0].cmd == "PASV" || this.eventQueue[0].cmd == "APPE2"
  2391.                                ||  this.eventQueue[0].cmd == "SIZE")) {
  2392.       var cmd       = this.eventQueue[0].cmd;
  2393.       var parameter = this.eventQueue[0].parameter;
  2394.       if (cmd == "LIST2" || cmd == "RETR2" || cmd == "STOR2" || cmd == "APPE2") {
  2395.         this.eventQueue[0].cmd = this.eventQueue[0].cmd.substring(0, 4);
  2396.       }
  2397.  
  2398.       cmd = this.eventQueue[0].cmd;
  2399.  
  2400.       if (cmd == "REST") {                                                       // set up resuming for these poor interrupted transfers
  2401.         try {
  2402.           var file = Components.classes['@mozilla.org/file/local;1'].createInstance(Components.interfaces.nsILocalFile);
  2403.           file.initWithPath(this.eventQueue[1].callback);
  2404.  
  2405.           if (file.fileSize) {
  2406.             this.eventQueue[0].parameter = file.fileSize;
  2407.           }
  2408.         } catch (ex) {
  2409.           if (this.observer) {
  2410.             this.observer.onDebug(ex);
  2411.           }
  2412.         }
  2413.       } else if (cmd == "RETR") {
  2414.         try {
  2415.           var file = Components.classes['@mozilla.org/file/local;1'].createInstance(Components.interfaces.nsILocalFile);
  2416.           file.initWithPath(this.eventQueue[0].callback);
  2417.  
  2418.           if (file.fileSize) {
  2419.             this.unshiftEventQueue("REST", file.fileSize, "");
  2420.           }
  2421.         } catch (ex) {
  2422.           if (this.observer) {
  2423.             this.observer.onDebug(ex);
  2424.           }
  2425.         }
  2426.       }
  2427.  
  2428.       for (var x = this.trashQueue.length - 1; x >= 0; --x) {                    // take cmds out of the trash and put them back in the eventQueue
  2429.         if (this.trashQueue[x].cmd == "TYPE" && (cmd == "STOR" || cmd == "APPE")) {   // more resuming fun - this time for the stor/appe commandds
  2430.           this.unshiftEventQueue("SIZE", parameter, cmd);
  2431.         }
  2432.  
  2433.         this.eventQueue.unshift(this.trashQueue[x]);
  2434.       }
  2435.     } else if (this.eventQueue.length && this.eventQueue[0].cmd == "RNTO" && this.trashQueue[this.trashQueue.length - 1].cmd == "RNFR") {
  2436.       this.unshiftEventQueue("RNFR", this.trashQueue[this.trashQueue.length - 1].parameter);
  2437.     }
  2438.  
  2439.     if (this.currentWorkingDir) {
  2440.       this.unshiftEventQueue("CWD", this.currentWorkingDir, true);
  2441.       this.currentWorkingDir = "";
  2442.     }
  2443.  
  2444.     this.trashQueue = new Array();
  2445.   }
  2446. };
  2447.